flink 77348858f4632e9b3987cf1ed6a9c8af4c5e1aeb

77348858f4632e9b3987cf1ed6a9c8af4c5e1aeb

Files Diff

Added: 0
Removed: 2
Renamed: 0
Modified: 8

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Variable	1
	Rename Variable jobIdShort : String to appIdShort : String in method public call() : DbStateHandle<S> in class org.apache.flink.contrib.streaming.state.DbStateBackend.checkpointStateSerializable.retry	From	To
	Rename Attribute	1
	Rename Attribute jobId : String to appId : String in class org.apache.flink.contrib.streaming.state.DbStateHandle	From	To
	Rename Parameter	14
	Rename Parameter jobId : String to appId : String in method public getCheckpoint(appId String, con Connection, checkpointId long, checkpointTs long, handleId long) : byte[] in class org.apache.flink.contrib.streaming.state.DbAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public createCheckpointsTable(appId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public DbStateHandle(appId String, checkpointId long, checkpointTs long, handleId long, dbConfig DbBackendConfig, stateSize long) in class org.apache.flink.contrib.streaming.state.DbStateHandle	From	To
	Rename Parameter jobId : String to appId : String in method public disposeAllStateForJob(appId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public getCheckpoint(appId String, con Connection, checkpointId long, checkpointTs long, handleId long) : byte[] in class org.apache.flink.contrib.streaming.state.MySqlAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public deleteCheckpoint(appId String, con Connection, checkpointId long, checkpointTs long, handleId long) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public disposeAllStateForJob(appId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.DbAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public setCheckpointInsertParams(appId String, insertStatement PreparedStatement, checkpointId long, timestamp long, handleId long, checkpoint byte[]) : void in class org.apache.flink.contrib.streaming.state.DbAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public prepareCheckpointInsert(appId String, con Connection) : PreparedStatement in class org.apache.flink.contrib.streaming.state.DbAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public deleteCheckpoint(appId String, con Connection, checkpointId long, checkpointTs long, handleId long) : void in class org.apache.flink.contrib.streaming.state.DbAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public createCheckpointsTable(appId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.DbAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public prepareCheckpointInsert(appId String, con Connection) : PreparedStatement in class org.apache.flink.contrib.streaming.state.MySqlAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public createCheckpointsTable(appId String, con Connection) : void in class org.apache.flink.contrib.streaming.state.DerbyAdapter	From	To
	Rename Parameter jobId : String to appId : String in method public setCheckpointInsertParams(appId String, insertStatement PreparedStatement, checkpointId long, timestamp long, handleId long, checkpoint byte[]) : void in class org.apache.flink.contrib.streaming.state.MySqlAdapter	From	To