|
Change Parameter Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in method public notifyKvStateRegistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress InetSocketAddress) : void in class org.apache.flink.runtime.query.KvStateLocationRegistry |
From |
To |
|
Change Parameter Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method private PendingConnection(serverAddress InetSocketAddress, serializer MessageSerializer<REQ,RESP>) in class org.apache.flink.queryablestate.network.Client.PendingConnection |
From |
To |
|
Change Parameter Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method package EstablishedConnection(serverAddress InetSocketAddress, serializer MessageSerializer<REQ,RESP>, channel Channel) in class org.apache.flink.queryablestate.network.Client.EstablishedConnection |
From |
To |
|
Change Parameter Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in method public notifyKvStateRegistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress InetSocketAddress) : void in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Parameter Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in method public notifyKvStateRegistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress InetSocketAddress) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public sendRequest(serverAddress InetSocketAddress, request REQ) : CompletableFuture<RESP> in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Parameter Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in method public ActorGatewayKvStateRegistryListener(jobManager ActorGateway, kvStateServerAddress InetSocketAddress) in class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener |
From |
To |
|
Change Parameter Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in method public RpcKvStateRegistryListener(kvStateRegistryGateway KvStateRegistryGateway, kvStateServerAddress InetSocketAddress) in class org.apache.flink.runtime.taskexecutor.rpc.RpcKvStateRegistryListener |
From |
To |
|
Change Parameter Type kvStateAddress : KvStateServerAddress to kvStateAddress : InetSocketAddress in method public registerKvState(keyGroupRange KeyGroupRange, kvStateId KvStateID, kvStateAddress InetSocketAddress) : void in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Change Parameter Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in method public NotifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress InetSocketAddress) in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateRegistered |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method public getKvStateServerAddress() : InetSocketAddress in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateRegistered |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method public getServerAddress() : InetSocketAddress in class org.apache.flink.queryablestate.network.AbstractServerBase |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method public getKvStateServerAddress(keyGroupIndex int) : InetSocketAddress in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method public getServerAddress() : InetSocketAddress in class org.apache.flink.queryablestate.server.KvStateServerImpl |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method public getServerAddress() : InetSocketAddress in class org.apache.flink.queryablestate.client.proxy.KvStateClientProxyImpl |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method public getServerAddress() : InetSocketAddress in class org.apache.flink.runtime.query.KvStateServer |
From |
To |
|
Change Return Type KvStateServerAddress to InetSocketAddress in method private getKvStateServerAddress(serverChannel Channel) : InetSocketAddress in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Move Class org.apache.flink.queryablestate.UnknownKeyOrNamespaceException moved to org.apache.flink.queryablestate.exceptions.UnknownKeyOrNamespaceException |
From |
To |
|
Move Class org.apache.flink.queryablestate.state.ImmutableListStateTest moved to org.apache.flink.queryablestate.client.state.ImmutableListStateTest |
From |
To |
|
Move Class org.apache.flink.queryablestate.state.ImmutableAggregatingStateTest moved to org.apache.flink.queryablestate.client.state.ImmutableAggregatingStateTest |
From |
To |
|
Move Class org.apache.flink.runtime.query.KvStateID moved to org.apache.flink.queryablestate.KvStateID |
From |
To |
|
Move Class org.apache.flink.queryablestate.state.ImmutableMapStateTest moved to org.apache.flink.queryablestate.client.state.ImmutableMapStateTest |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.message.KvStateSerializer moved to org.apache.flink.queryablestate.client.state.serialization.KvStateSerializer |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.AtomicKvStateRequestStats moved to org.apache.flink.queryablestate.network.stats.AtomicKvStateRequestStats |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.KvStateRequestStats moved to org.apache.flink.queryablestate.network.stats.KvStateRequestStats |
From |
To |
|
Move Class org.apache.flink.queryablestate.UnknownJobManagerException moved to org.apache.flink.queryablestate.exceptions.UnknownJobManagerException |
From |
To |
|
Move Class org.apache.flink.queryablestate.state.ImmutableValueStateTest moved to org.apache.flink.queryablestate.client.state.ImmutableValueStateTest |
From |
To |
|
Move Class org.apache.flink.queryablestate.UnknownKvStateKeyGroupLocationException moved to org.apache.flink.queryablestate.exceptions.UnknownKvStateKeyGroupLocationException |
From |
To |
|
Move Class org.apache.flink.queryablestate.UnknownKvStateIdException moved to org.apache.flink.queryablestate.exceptions.UnknownKvStateIdException |
From |
To |
|
Move Class org.apache.flink.queryablestate.state.ImmutableFoldingStateTest moved to org.apache.flink.queryablestate.client.state.ImmutableFoldingStateTest |
From |
To |
|
Move Class org.apache.flink.queryablestate.state.ImmutableReducingStateTest moved to org.apache.flink.queryablestate.client.state.ImmutableReducingStateTest |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.DisabledKvStateRequestStats moved to org.apache.flink.queryablestate.network.stats.DisabledKvStateRequestStats |
From |
To |
|
Move Class org.apache.flink.runtime.query.netty.message.KvStateRequestSerializerTest moved to org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method private getState(request KvStateRequest, forceUpdate boolean) : CompletableFuture<KvStateResponse> in class org.apache.flink.queryablestate.client.proxy.KvStateClientProxyHandler |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public testFailureClosesChannel() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public testRequestUnavailableHost() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public testConcurrentQueries() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public testSimpleRequests() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public testServerClosesChannel() : void in class org.apache.flink.queryablestate.network.ClientTest |
From |
To |
|
Change Variable Type conn : Map.Entry<KvStateServerAddress,EstablishedConnection> to conn : Map.Entry<InetSocketAddress,EstablishedConnection> in method public shutdown() : void in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Variable Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in method public testSimpleRequest() : void in class org.apache.flink.queryablestate.network.KvStateServerTest |
From |
To |
|
Change Variable Type conn : Map.Entry<KvStateServerAddress,PendingConnection> to conn : Map.Entry<InetSocketAddress,PendingConnection> in method public shutdown() : void in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Variable Type server : KvStateServerAddress to server : InetSocketAddress in method public testRegisterAndLookup() : void in class org.apache.flink.runtime.query.KvStateLocationRegistryTest |
From |
To |
|
Change Attribute Type establishedConnections : Map<KvStateServerAddress,EstablishedConnection> to establishedConnections : Map<InetSocketAddress,EstablishedConnection> in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Attribute Type pendingConnections : Map<KvStateServerAddress,PendingConnection> to pendingConnections : Map<InetSocketAddress,PendingConnection> in class org.apache.flink.queryablestate.network.Client |
From |
To |
|
Change Attribute Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in class org.apache.flink.runtime.taskexecutor.rpc.RpcKvStateRegistryListener |
From |
To |
|
Change Attribute Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in class org.apache.flink.queryablestate.network.AbstractServerBase |
From |
To |
|
Change Attribute Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in class org.apache.flink.queryablestate.network.Client.EstablishedConnection |
From |
To |
|
Change Attribute Type serverAddress : KvStateServerAddress to serverAddress : InetSocketAddress in class org.apache.flink.queryablestate.network.Client.PendingConnection |
From |
To |
|
Change Attribute Type remoteAddress : KvStateServerAddress to remoteAddress : InetSocketAddress in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Attribute Type kvStateAddresses : KvStateServerAddress[] to kvStateAddresses : InetSocketAddress[] in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Change Attribute Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateRegistered |
From |
To |
|
Change Attribute Type kvStateServerAddress : KvStateServerAddress to kvStateServerAddress : InetSocketAddress in class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener |
From |
To |