|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testQueryNonStartedJobState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type server : KvStateServer to server : KvStateServerImpl in method public testSimpleRequest() : void in class org.apache.flink.queryablestate.network.KvStateServerTest |
From |
To |
|
Change Variable Type result : Future<byte[]> to result : CompletableFuture<KvStateResponse> in method public testConcurrentQueries() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type response : KvStateRequestFailure to response : RequestFailure in method public testQueryUnknownKey() : void in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type futures : List<Future<Tuple2<Integer,Long>>> to futures : List<CompletableFuture<Tuple2<Integer,Long>>> in method public testQueryableState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type numElements : int to numElements : long in method public testValueState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testFoldingState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type futures : List<Future<byte[]>> to futures : List<Future<KvStateResponse>> in method public testFailureClosesChannel() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type pending : PromiseAndTimestamp to pending : TimestampedCompletableFuture in method public onRequestResult(requestId long, response RESP) : void in class org.apache.flink.queryablestate.network.Client.EstablishedConnection |
From |
To |
|
Change Variable Type client : KvStateClient to client : Client<KvStateInternalRequest,KvStateResponse> in method public testClientServerIntegration() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type future : Future<Tuple2<Integer,Long>> to future : CompletableFuture<Tuple2<Integer,Long>> in method public testValueStateDefault() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type finalClient : KvStateClient to finalClient : Client<KvStateInternalRequest,KvStateResponse> in method public testConcurrentQueries() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type request : KvStateRequestFailure to requestFailure : RequestFailure in method public testKvStateRequestFailureSerialization() : void in class org.apache.flink.queryablestate.network.MessageSerializerTest |
From |
To |
|
Change Variable Type pending : PromiseAndTimestamp to pending : TimestampedCompletableFuture in method public onRequestFailure(requestId long, cause Throwable) : void in class org.apache.flink.queryablestate.network.Client.EstablishedConnection |
From |
To |
|
Change Variable Type finalClient : KvStateClient to finalClient : Client<KvStateInternalRequest,KvStateResponse> in method public testClientServerIntegration() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type future : Future<List<Future<byte[]>>> to future : Future<List<CompletableFuture<KvStateResponse>>> in method public testConcurrentQueries() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type i : int to i : long in method public testSimpleRequests() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type bufferPool : NettyBufferPool to bufferPool : ByteBufAllocator in method public Client(clientName String, numEventLoopThreads int, serializer MessageSerializer<REQ,RESP>, stats KvStateRequestStats) in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Variable Type future : Future<Tuple2<Integer,Long>> to future : CompletableFuture<Tuple2<Integer,Long>> in method private executeQuery(deadline Deadline, client QueryableStateClient, jobId JobID, queryableStateName String, stateDescriptor StateDescriptor<?,Tuple2<Integer,Long>>, expected long) : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testReducingState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type numElements : int to numElements : long in method public testReducingState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type failedFuture : Future<TestingJobManagerMessages.JobStatusIs> to failedFuture : CompletableFuture<TestingJobManagerMessages.JobStatusIs> in method public testDuplicateRegistrationFailsJob() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type future : Future<String> to future : CompletableFuture<String> in method public testFoldingState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testValueStateDefault() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type client : KvStateClient to client : Client<KvStateInternalRequest,KvStateResponse> in method public testRequestUnavailableHost() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type futures : List<Future<byte[]>> to futures : List<CompletableFuture<KvStateResponse>> in method public testSimpleRequests() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type sleepMillis : int to sleepMillis : long in method private readInboundBlocking(channel EmbeddedChannel) : Object in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type response : KvStateRequestFailure to response : RequestFailure in method public testQueryExecutorShutDown() : void in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testValueStateShortcut() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type request : KvStateRequest to requestDeser : KvStateInternalRequest in method public testRequestSerialization() : void in class org.apache.flink.queryablestate.network.MessageSerializerTest |
From |
To |
|
Change Variable Type sleptMillis : int to sleptMillis : long in method private readInboundBlocking(channel EmbeddedChannel) : Object in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type numElements : int to numElements : long in method public testValueStateShortcut() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type pending : PromiseAndTimestamp to pending : TimestampedCompletableFuture in method private close(cause Throwable) : boolean in class org.apache.flink.queryablestate.network.Client.EstablishedConnection |
From |
To |
|
Change Variable Type client : KvStateClient to client : Client<KvStateInternalRequest,KvStateResponse> in method public testFailureClosesChannel() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type result : Future<Tuple2<Integer,Long>> to result : CompletableFuture<Tuple2<Integer,Long>> in method public testQueryableState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type client : KvStateClient to client : Client<KvStateInternalRequest,KvStateResponse> in method public testServerClosesChannel() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type response : KvStateRequestFailure to response : RequestFailure in method public testQueryUnknownKvStateID() : void in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type client : KvStateClient to client : Client<KvStateInternalRequest,KvStateResponse> in method public testConcurrentQueries() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type future : java.util.concurrent.Future<Void> to future : Future<Void> in method public testClientServerIntegration() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type client : KvStateClient to client : Client<KvStateInternalRequest,KvStateResponse> in method public testSimpleRequests() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type numElements : int to numElements : long in method public testQueryNonStartedJobState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testQueryableState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type expectedRequests : int to expectedRequests : long in method public testSimpleRequests() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type cancellation : Future<CancellationSuccess> to cancellation : CompletableFuture<CancellationSuccess> in method public testValueState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type numElements : int to numElements : long in method public testValueStateDefault() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type response : KvStateRequestFailure to response : RequestFailure in method public testFailureOnGetSerializedValue() : void in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type response : KvStateRequestFailure to response : RequestFailure in method public testSerializerMismatch() : void in class org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Change Variable Type numQueries : int to numQueries : long in method public testSimpleRequests() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type results : List<Future<byte[]>> to results : List<CompletableFuture<KvStateResponse>> in method public testConcurrentQueries() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Rename Method public deserializeKvStateRequestFailure(buf ByteBuf) : KvStateRequestFailure renamed to public deserializeRequestFailure(buf ByteBuf) : RequestFailure in class org.apache.flink.queryablestate.network.messages.MessageSerializer |
From |
To |
|
Rename Method public shutDown() : void renamed to public shutdown() : void in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Rename Method public shutDown() : void renamed to public shutdown() : void in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Rename Method public testKvStateRequestSerialization() : void renamed to public testRequestSerialization() : void in class org.apache.flink.queryablestate.network.MessageSerializerTest |
From |
To |
|
Rename Method public getKvState(serverAddress KvStateServerAddress, kvStateId KvStateID, serializedKeyAndNamespace byte[]) : Future<byte[]> renamed to public sendRequest(serverAddress KvStateServerAddress, request REQ) : CompletableFuture<RESP> in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Rename Method public serializeKvStateRequestResult(alloc ByteBufAllocator, requestId long, serializedResult byte[]) : ByteBuf renamed to public serializeRequest(alloc ByteBufAllocator, requestId long, request REQ) : ByteBuf in class org.apache.flink.queryablestate.network.messages.MessageSerializer |
From |
To |
|
Rename Method public serializeKvStateRequestFailure(alloc ByteBufAllocator, requestId long, cause Throwable) : ByteBuf renamed to public serializeRequestFailure(alloc ByteBufAllocator, requestId long, cause Throwable) : ByteBuf in class org.apache.flink.queryablestate.network.messages.MessageSerializer |
From |
To |
|
Rename Method public shutDown() : void renamed to public shutdown() : void in class org.apache.flink.queryablestate.server.KvStateServerImpl |
From |
To |
|
Rename Method public testKvStateRequestResultSerialization() : void renamed to public testResponseSerialization() : void in class org.apache.flink.queryablestate.network.MessageSerializerTest |
From |
To |
|
Rename Method public shutDown() : void renamed to public shutdown() : void in class org.apache.flink.runtime.query.KvStateServer |
From |
To |
|
Change Return Type Future<byte[]> to CompletableFuture<RESP> in method public sendRequest(serverAddress KvStateServerAddress, request REQ) : CompletableFuture<RESP> in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Return Type KvStateRequest to KvStateInternalRequest in method public deserializeMessage(buf ByteBuf) : KvStateInternalRequest in class org.apache.flink.queryablestate.messages.KvStateInternalRequest.KvStateInternalRequestDeserializer |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public getKvState(jobId JobID, queryableStateName String, key K, namespace N, keyTypeInfo TypeInformation<K>, namespaceTypeInfo TypeInformation<N>, stateDescriptor StateDescriptor<?,V>) : CompletableFuture<V> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public getKvState(jobId JobID, queryableStateName String, key K, keyTypeHint TypeHint<K>, stateDescriptor StateDescriptor<?,V>) : CompletableFuture<V> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Return Type KvStateRequestResult to KvStateInternalRequest in method public deserializeMessage(buf ByteBuf) : KvStateInternalRequest in class org.apache.flink.queryablestate.messages.KvStateInternalRequest.KvStateInternalRequestDeserializer |
From |
To |
|
Change Return Type KvStateRequestFailure to RequestFailure in method public deserializeRequestFailure(buf ByteBuf) : RequestFailure in class org.apache.flink.queryablestate.network.messages.MessageSerializer |
From |
To |
|
Change Return Type void to ExecutionConfig in method public setExecutionConfig(config ExecutionConfig) : ExecutionConfig in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public getKvState(jobId JobID, queryableStateName String, key K, keyTypeInfo TypeInformation<K>, stateDescriptor StateDescriptor<?,V>) : CompletableFuture<V> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public getKvState(jobId JobID, queryableStateName String, key K, namespace N, keyTypeInfo TypeInformation<K>, namespaceTypeInfo TypeInformation<N>, stateSerializer TypeSerializer<V>) : CompletableFuture<V> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |