|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateUnregistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : void in class org.apache.flink.runtime.query.KvStateLocationRegistry |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public registerKvState(keyGroupRange KeyGroupRange, registrationName String, kvState KvState<?>) : void in class org.apache.flink.runtime.query.TaskKvStateRegistry |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public registerKvState(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvState KvState<?>) : KvStateID in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.query.KvStateRegistryListener |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress KvStateServerAddress) : void in class org.apache.flink.runtime.query.KvStateLocationRegistry |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : void in class org.apache.flink.runtime.query.KvStateRegistryListener |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public KvStateInfo(keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) in class org.apache.flink.runtime.query.TaskKvStateRegistry.KvStateInfo |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest.TestRegistryListener |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public NotifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateUnregistered |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public unregisterKvState(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method package unregisterKvState(keyGroupRange KeyGroupRange) : void in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public NotifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress KvStateServerAddress) in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateRegistered |
From |
To |
|
Change Parameter Type keyGroupIndex : int to keyGroupRange : KeyGroupRange in method package registerKvState(keyGroupRange KeyGroupRange, kvStateId KvStateID, kvStateAddress KvStateServerAddress) : void in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public unregisterKvState(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateUnregistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : void in class org.apache.flink.runtime.query.KvStateLocationRegistry |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : void in class org.apache.flink.runtime.query.KvStateRegistryListener |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public KvStateInfo(keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) in class org.apache.flink.runtime.query.TaskKvStateRegistry.KvStateInfo |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public registerKvState(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvState KvState<?>) : KvStateID in class org.apache.flink.runtime.query.KvStateRegistry |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public NotifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateUnregistered |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method package unregisterKvState(keyGroupRange KeyGroupRange) : void in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public NotifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress KvStateServerAddress) in class org.apache.flink.runtime.query.KvStateMessage.NotifyKvStateRegistered |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.query.KvStateRegistryListener |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method package registerKvState(keyGroupRange KeyGroupRange, kvStateId KvStateID, kvStateAddress KvStateServerAddress) : void in class org.apache.flink.runtime.query.KvStateLocation |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress KvStateServerAddress) : void in class org.apache.flink.runtime.query.KvStateLocationRegistry |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public registerKvState(keyGroupRange KeyGroupRange, registrationName String, kvState KvState<?>) : void in class org.apache.flink.runtime.query.TaskKvStateRegistry |
From |
To |
|
Rename Parameter parallelism : int to maxParallelism : int in method private createJobVertex(maxParallelism int) : ExecutionJobVertex in class org.apache.flink.runtime.query.KvStateLocationRegistryTest |
From |
To |
|
Rename Parameter keyGroupIndex : int to keyGroupRange : KeyGroupRange in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID) : void in class org.apache.flink.runtime.query.netty.KvStateServerHandlerTest.TestRegistryListener |
From |
To |