3667ea605ec9002df225493f0a0b5a6840b6f28d
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable remoteSender : boolean to isRemoteSender : boolean in method private handleRpcInvocation(rpcInvocation RpcInvocation) : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActor | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Either<SerializedValue,AkkaRpcException> to Either<SerializedValue<?>,AkkaRpcException> in method private serializeRemoteResultAndVerifySize(result Object, methodName String) : Either<SerializedValue<?>,AkkaRpcException> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActor | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.TestRpcEndpoint moved to org.apache.flink.runtime.rpc.akka.TestRpcEndpoint | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type serializedResult : Either<SerializedValue,AkkaRpcException> to serializedResult : Either<SerializedValue<?>,AkkaRpcException> in method private handleRpcInvocation(rpcInvocation RpcInvocation) : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActor | From | To | |
| Change Variable Type resultFuture : CompletableFuture to resultFuture : CompletableFuture<?> in method private invokeRpc(method Method, args Object[]) : Object in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler | From | To | |
| Change Variable Type completableFuture : CompletableFuture to completableFuture : CompletableFuture<?> in method private invokeRpc(method Method, args Object[]) : Object in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler | From | To |