|
Change Parameter Type defaultTimeout : Timeout to defaultTimeout : Time in method private extractRpcTimeout(parameterAnnotations Annotation[][], args Object[], defaultTimeout Time) : Time in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Parameter Type defaultTimeout : Timeout to defaultTimeout : Time in method private extractRpcTimeout(parameterAnnotations Annotation[][], args Object[], defaultTimeout Time) : Time in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Parameter Type timeout : Timeout to timeout : Time in method public AkkaRpcService(actorSystem ActorSystem, timeout Time) in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public TaskExecutorToResourceManagerConnection(log Logger, taskExecutor TaskExecutor, resourceManagerAddress String, resourceManagerLeaderId UUID, executor Executor) in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection |
From |
To |
|
Change Parameter Type timeout : Timeout to timeout : Time in method package AkkaInvocationHandler(address String, rpcEndpoint ActorRef, timeout Time, maximumFramesize long) in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Parameter Type promise : Promise<?> to promise : CompletableFuture<?> in method private FutureTimeout(promise CompletableFuture<?>) in class org.apache.flink.runtime.rpc.TestingGatewayBase.FutureTimeout |
From |
To |
|
Change Parameter Type timeout : Timeout to timeout : Time in method protected callAsync(callable Callable<V>, timeout Time) : Future<V> in class org.apache.flink.runtime.rpc.RpcEndpoint |
From |
To |
|
Change Parameter Type timeout : Timeout to timeout : Time in method private TestingSerialInvocationHandler(address String, rpcEndpoint T, timeout Time) in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Parameter Type callTimeout : Timeout to callTimeout : Time in method public callAsync(callable Callable<V>, callTimeout Time) : Future<V> in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Parameter Type callTimeout : Timeout to callTimeout : Time in method public callAsync(callable Callable<V>, callTimeout Time) : Future<V> in class org.apache.flink.runtime.rpc.MainThreadExecutable |
From |
To |
|
Change Parameter Type futureTimeout : Timeout to futureTimeout : Time in method private handleRpcInvocationSync(methodName String, parameterTypes Class<?>[], args Object[], futureTimeout Time) : Object in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Return Type ExecutionContext to Executor in method public getExecutor() : Executor in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Return Type Timeout to Time in method private extractRpcTimeout(parameterAnnotations Annotation[][], args Object[], defaultTimeout Time) : Time in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Return Type ExecutionContext to Executor in method public getExecutor() : Executor in class org.apache.flink.runtime.rpc.RpcService |
From |
To |
|
Change Return Type ExecutionContext to Executor in method public getExecutor() : Executor in class org.apache.flink.runtime.rpc.TestingSerialRpcService |
From |
To |
|
Change Return Type Timeout to Time in method private extractRpcTimeout(parameterAnnotations Annotation[][], args Object[], defaultTimeout Time) : Time in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Variable Type promise : Promise<T> to future : FlinkCompletableFuture<T> in method public futureWithTimeout(timeoutMillis long) : Future<T> in class org.apache.flink.runtime.rpc.TestingGatewayBase |
From |
To |
|
Change Variable Type futureTimeout : Timeout to futureTimeout : Time in method public invoke(proxy Object, method Method, args Object[]) : Object in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Variable Type futureTimeout : Timeout to futureTimeout : Time in method public invoke(proxy Object, method Method, args Object[]) : Object in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Variable Type result : Future<V> to result : scala.concurrent.Future<V> in method public callAsync(callable Callable<V>, callTimeout Time) : Future<V> in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Attribute Type timeout : Timeout to timeout : Time in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Attribute Type timeout : FiniteDuration to timeout : Time in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager |
From |
To |
|
Change Attribute Type mainThreadExecutionContext : ExecutionContext to mainThreadExecutor : Executor in class org.apache.flink.runtime.rpc.RpcEndpoint |
From |
To |
|
Change Attribute Type timeout : Timeout to timeout : Time in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Attribute Type timeout : Timeout to timeout : Time in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Attribute Type timeout : Timeout to timeout : Time in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Attribute Type timeout : FiniteDuration to timeout : Time in class org.apache.flink.runtime.rpc.akka.MessageSerializationTest |
From |
To |
|
Change Attribute Type promise : Promise<?> to promise : CompletableFuture<?> in class org.apache.flink.runtime.rpc.TestingGatewayBase.FutureTimeout |
From |
To |
|
Change Attribute Type executionContext : ExecutionContext to executor : Executor in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection |
From |
To |