flink cef6741a91fcb83757a82a39b04d074b1a1311cf

cef6741a91fcb83757a82a39b04d074b1a1311cf

Files Diff

Added: 6
Removed: 2
Renamed: 0
Modified: 15

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Method	1
	Rename Method public lookupKvStateLocation(registrationName String) : CompletableFuture<KvStateLocation> renamed to public requestKvStateLocation(jobId JobID, registrationName String) : CompletableFuture<KvStateLocation> in class org.apache.flink.runtime.jobmaster.JobMaster	From	To
	Change Return Type	4
	Change Return Type void to CompletableFuture<Acknowledge> in method public notifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster	From	To
	Change Return Type void to CompletableFuture<Acknowledge> in method public notifyKvStateUnregistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.KvStateRegistryGateway	From	To
	Change Return Type void to CompletableFuture<Acknowledge> in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress InetSocketAddress) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.KvStateRegistryGateway	From	To
	Change Return Type void to CompletableFuture<Acknowledge> in method public notifyKvStateRegistered(jobId JobID, jobVertexId JobVertexID, keyGroupRange KeyGroupRange, registrationName String, kvStateId KvStateID, kvStateServerAddress InetSocketAddress) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster	From	To
	Rename Class	1
	Rename Class org.apache.flink.queryablestate.exceptions.UnknownJobManagerException renamed to org.apache.flink.queryablestate.exceptions.UnknownLocationException	From	To
	Move Class	1
	Move Class org.apache.flink.runtime.query.KvStateRegistryGateway moved to org.apache.flink.runtime.jobmaster.KvStateRegistryGateway	From	To
	Extract Variable	1
	Extract Variable jobId : JobID in method public testSimpleRequest() : void from class org.apache.flink.queryablestate.network.KvStateServerTest	From	To