|
Move Method public createKvStateTaskRegistry(jobId JobID, jobVertexId JobVertexID) : TaskKvStateRegistry from class org.apache.flink.runtime.io.network.NetworkEnvironment to public createKvStateTaskRegistry(jobId JobID, jobVertexId JobVertexID) : TaskKvStateRegistry from class org.apache.flink.runtime.taskexecutor.KvStateService |
From |
To |
|
Move Method public getKvStateServer() : KvStateServer from class org.apache.flink.runtime.io.network.NetworkEnvironment to public getKvStateServer() : KvStateServer from class org.apache.flink.runtime.taskexecutor.KvStateService |
From |
To |
|
Move Method public getKvStateRegistry() : KvStateRegistry from class org.apache.flink.runtime.io.network.NetworkEnvironment to public getKvStateRegistry() : KvStateRegistry from class org.apache.flink.runtime.taskexecutor.KvStateService |
From |
To |