|
Change Parameter Type numEventLoopThreads : int to numEventLoopThreads : Integer in method public KvStateServerImpl(bindAddress InetAddress, bindPort Integer, numEventLoopThreads Integer, numQueryThreads Integer, kvStateRegistry KvStateRegistry, stats KvStateRequestStats) in class org.apache.flink.queryablestate.server.KvStateServerImpl |
From |
To |
|
Change Parameter Type bindPort : int to bindPort : Integer in method public KvStateServerImpl(bindAddress InetAddress, bindPort Integer, numEventLoopThreads Integer, numQueryThreads Integer, kvStateRegistry KvStateRegistry, stats KvStateRequestStats) in class org.apache.flink.queryablestate.server.KvStateServerImpl |
From |
To |
|
Change Parameter Type numQueryThreads : int to numQueryThreads : Integer in method public KvStateServerImpl(bindAddress InetAddress, bindPort Integer, numEventLoopThreads Integer, numQueryThreads Integer, kvStateRegistry KvStateRegistry, stats KvStateRequestStats) in class org.apache.flink.queryablestate.server.KvStateServerImpl |
From |
To |
|
Move Method public testNullPointerExceptionOnNullSerializedKeyAndNamepsace() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testNullPointerExceptionOnNullSerializedKeyAndNamepsace() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public deserializeKeyAndNamespace(serializedKeyAndNamespace byte[], keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>) : Tuple2<K,N> from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public deserializeKeyAndNamespace(serializedKeyAndNamespace byte[], keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>) : Tuple2<K,N> from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Method public deserializeValue(serializedValue byte[], serializer TypeSerializer<T>) : T from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public deserializeValue(serializedValue byte[], serializer TypeSerializer<T>) : T from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Method public testKvStateRequestSerialization() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testKvStateRequestSerialization() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public testNullPointerExceptionOnNullSerializedResult() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testNullPointerExceptionOnNullSerializedResult() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public testKvStateRequestFailureSerialization() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testKvStateRequestFailureSerialization() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public testServerFailureSerialization() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testServerFailureSerialization() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public serializeKeyAndNamespace(key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>) : byte[] from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public serializeKeyAndNamespace(key K, keySerializer TypeSerializer<K>, namespace N, namespaceSerializer TypeSerializer<N>) : byte[] from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Method public testKvStateRequestResultSerialization() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testKvStateRequestResultSerialization() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public serializeMap(entries Iterable<Map.Entry<UK,UV>>, keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>) : byte[] from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public serializeMap(entries Iterable<Map.Entry<UK,UV>>, keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>) : byte[] from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Method public testKvStateRequestResultSerializationWithZeroLengthSerializedResult() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testKvStateRequestResultSerializationWithZeroLengthSerializedResult() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public testKvStateRequestSerializationWithZeroLengthKeyAndNamespace() : void from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest to public testKvStateRequestSerializationWithZeroLengthKeyAndNamespace() : void from class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Move Method public serializeValue(value T, serializer TypeSerializer<T>) : byte[] from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public serializeValue(value T, serializer TypeSerializer<T>) : byte[] from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Method public deserializeList(serializedValue byte[], serializer TypeSerializer<T>) : List<T> from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public deserializeList(serializedValue byte[], serializer TypeSerializer<T>) : List<T> from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Method public deserializeMap(serializedValue byte[], keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>) : Map<UK,UV> from class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializer to public deserializeMap(serializedValue byte[], keySerializer TypeSerializer<UK>, valueSerializer TypeSerializer<UV>) : Map<UK,UV> from class org.apache.flink.runtime.query.netty.message.KvStateSerializer |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.ChunkedByteBuf moved to org.apache.flink.queryablestate.server.ChunkedByteBuf |
From |
To |
|
Move Class org.apache.flink.runtime.query.QueryableStateClientTest moved to org.apache.flink.queryablestate.network.QueryableStateClientTest |
From |
To |
|
Move Class org.apache.flink.test.query.KVStateRequestSerializerRocksDBTest moved to org.apache.flink.queryablestate.itcases.KVStateRequestSerializerRocksDBTest |
From |
To |
|
Move Class org.apache.flink.test.query.NonHAQueryableStateITCaseFsBackend moved to org.apache.flink.queryablestate.itcases.NonHAQueryableStateITCaseFsBackend |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateServerTest moved to org.apache.flink.queryablestate.network.KvStateServerTest |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.message.KvStateRequestResult moved to org.apache.flink.queryablestate.messages.KvStateRequestResult |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.UnknownKeyOrNamespace moved to org.apache.flink.queryablestate.UnknownKeyOrNamespace |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateClientHandler moved to org.apache.flink.queryablestate.client.KvStateClientHandler |
From |
To |
|
Move Class org.apache.flink.test.query.NonHAQueryableStateITCaseRocksDBBackend moved to org.apache.flink.queryablestate.itcases.NonHAQueryableStateITCaseRocksDBBackend |
From |
To |
|
Move Class org.apache.flink.runtime.query.UnknownJobManager moved to org.apache.flink.queryablestate.UnknownJobManager |
From |
To |
|
Move Class org.apache.flink.test.query.AbstractQueryableStateITCase moved to org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateClient moved to org.apache.flink.queryablestate.client.KvStateClient |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateServerHandler moved to org.apache.flink.queryablestate.server.KvStateServerHandler |
From |
To |
|
Move Class org.apache.flink.test.query.NonHAAbstractQueryableStateITCase moved to org.apache.flink.queryablestate.itcases.NonHAAbstractQueryableStateITCase |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.message.KvStateRequestFailure moved to org.apache.flink.queryablestate.messages.KvStateRequestFailure |
From |
To |
|
Move Class org.apache.flink.runtime.query.UnknownKvStateKeyGroupLocation moved to org.apache.flink.queryablestate.UnknownKvStateKeyGroupLocation |
From |
To |
|
Move Class org.apache.flink.test.query.HAQueryableStateITCaseFsBackend moved to org.apache.flink.queryablestate.itcases.HAQueryableStateITCaseFsBackend |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateClientHandlerCallback moved to org.apache.flink.queryablestate.client.KvStateClientHandlerCallback |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest moved to org.apache.flink.queryablestate.network.KvStateServerHandlerTest |
From |
To |
|
Move Class org.apache.flink.test.query.HAAbstractQueryableStateITCase moved to org.apache.flink.queryablestate.itcases.HAAbstractQueryableStateITCase |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.message.KvStateRequest moved to org.apache.flink.queryablestate.messages.KvStateRequest |
From |
To |
|
Move Class org.apache.flink.runtime.query.QueryableStateClient moved to org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Move Class org.apache.flink.runtime.query.KvStateLocationLookupService moved to org.apache.flink.queryablestate.client.KvStateLocationLookupService |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.UnknownKvStateID moved to org.apache.flink.queryablestate.UnknownKvStateID |
From |
To |
|
Move Class org.apache.flink.runtime.query.AkkaKvStateLocationLookupServiceTest moved to org.apache.flink.queryablestate.network.AkkaKvStateLocationLookupServiceTest |
From |
To |
|
Move Class org.apache.flink.test.query.HAQueryableStateITCaseRocksDBBackend moved to org.apache.flink.queryablestate.itcases.HAQueryableStateITCaseRocksDBBackend |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateClientHandlerTest moved to org.apache.flink.queryablestate.network.KvStateClientHandlerTest |
From |
To |
|
Move Class org.apache.flink.runtime.query.AkkaKvStateLocationLookupService moved to org.apache.flink.queryablestate.client.AkkaKvStateLocationLookupService |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateClientTest moved to org.apache.flink.queryablestate.network.KvStateClientTest |
From |
To |
|
Change Variable Type out : ObjectOutputStream to out : ObjectOutput in method public serializeKvStateRequestFailure(alloc ByteBufAllocator, requestId long, cause Throwable) : ByteBuf in class org.apache.flink.queryablestate.network.messages.MessageSerializer |
From |
To |
|
Change Variable Type retryStrategy : LookupRetryStrategyFactory to retryStrategy : AkkaKvStateLocationLookupService.LookupRetryStrategyFactory in method public QueryableStateClient(config Configuration, highAvailabilityServices HighAvailabilityServices) in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Variable Type out : ObjectOutputStream to out : ObjectOutput in method public serializeServerFailure(alloc ByteBufAllocator, cause Throwable) : ByteBuf in class org.apache.flink.queryablestate.network.messages.MessageSerializer |
From |
To |
|
Change Variable Type cancellation : Future<JobManagerMessages.CancellationSuccess> to cancellation : Future<CancellationSuccess> in method public testDuplicateRegistrationFailsJob() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type retryStrategy : LookupRetryStrategyFactory to retryStrategy : AkkaKvStateLocationLookupService.LookupRetryStrategyFactory in method public testRetryOnUnknownJobManager() : void in class org.apache.flink.queryablestate.network.AkkaKvStateLocationLookupServiceTest |
From |
To |
|
Change Variable Type msgType : KvStateRequestType to msgType : MessageType in method public channelRead(ctx ChannelHandlerContext, msg Object) : void in class org.apache.flink.queryablestate.server.KvStateServerHandler |
From |
To |
|
Change Variable Type msgType : KvStateRequestType to msgType : MessageType in method public channelRead(ctx ChannelHandlerContext, msg Object) : void in class org.apache.flink.queryablestate.client.KvStateClientHandler |
From |
To |
|
Change Variable Type retryStrategies : Queue<LookupRetryStrategy> to retryStrategies : Queue<AkkaKvStateLocationLookupService.LookupRetryStrategy> in method public testRetryOnUnknownJobManager() : void in class org.apache.flink.queryablestate.network.AkkaKvStateLocationLookupServiceTest |
From |
To |