4947ee669fe267e3f71853cd14228b350cf10ac8
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getRpcEndpoint() : ActorRef renamed to public getActorRef() : ActorRef in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in method package AkkaInvocationHandler(address String, hostname String, rpcEndpoint ActorRef, timeout Time, maximumFramesize long, terminationFuture CompletableFuture<Boolean>, internalTerminationFuture CompletableFuture<Void>) in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler | From | To | |
| Change Parameter Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in method public FencedAkkaInvocationHandler(address String, hostname String, rpcEndpoint ActorRef, timeout Time, maximumFramesize long, terminationFuture CompletableFuture<Boolean>, internalTerminationFuture CompletableFuture<Void>, fencingTokenSupplier Supplier<F>) in class org.apache.flink.runtime.rpc.akka.FencedAkkaInvocationHandler | From | To | |
| Change Return Type | 4 | ||
| Change Return Type CompletableFuture<Void> to CompletableFuture<Boolean> in method public getTerminationFuture() : CompletableFuture<Boolean> in class org.apache.flink.runtime.rpc.RpcEndpoint | From | To | |
| Change Return Type CompletableFuture<Void> to CompletableFuture<Boolean> in method public getTerminationFuture() : CompletableFuture<Boolean> in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler | From | To | |
| Change Return Type CompletableFuture<Void> to CompletableFuture<Boolean> in method public getTerminationFuture() : CompletableFuture<Boolean> in class org.apache.flink.runtime.rpc.RpcServer | From | To | |
| Change Return Type CompletableFuture<Void> to CompletableFuture<Boolean> in method public getTerminationFuture() : CompletableFuture<Boolean> in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute terminationFuture : CompletableFuture<Void> to internalTerminationFuture : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActor | From | To | |
| Change Variable Type | 5 | ||
| Change Variable Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in method public startServer(rpcEndpoint C) : RpcServer in class org.apache.flink.runtime.rpc.akka.AkkaRpcService | From | To | |
| Change Variable Type akkaClient : AkkaGateway to akkaClient : AkkaBasedEndpoint in method public stopServer(selfGateway RpcServer) : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcService | From | To | |
| Change Variable Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in method public testPostStopExecutedByMainThread() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest | From | To | |
| Change Variable Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in method public testPostStopExceptionPropagation() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest | From | To | |
| Change Variable Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in method public testRpcEndpointTerminationFuture() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest | From | To | |
| Split Variable | 1 | ||
| Split Variable address : String to [akkaAddress : String, internalTerminationFuture : CompletableFuture<Void>] in method public startServer(rpcEndpoint C) : RpcServer in class org.apache.flink.runtime.rpc.akka.AkkaRpcService | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type actors : Set<ActorRef> to actors : Map<ActorRef,RpcEndpoint> in class org.apache.flink.runtime.rpc.akka.AkkaRpcService | From | To | |
| Change Attribute Type terminationFuture : CompletableFuture<Void> to terminationFuture : CompletableFuture<Boolean> in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter terminationFuture : CompletableFuture<Void> to internalTerminationFuture : CompletableFuture<Void> in method package AkkaRpcActor(rpcEndpoint T, internalTerminationFuture CompletableFuture<Void>) in class org.apache.flink.runtime.rpc.akka.AkkaRpcActor | From | To | |
| Rename Parameter terminationFuture : CompletableFuture<Void> to internalTerminationFuture : CompletableFuture<Void> in method public FencedAkkaRpcActor(rpcEndpoint T, internalTerminationFuture CompletableFuture<Void>) in class org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor | From | To |