|
Change Parameter Type con : Connection to cons : ShardedConnection in method private initDB(cons ShardedConnection) : void in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Parameter Type con : Connection to cons : ShardedConnection in method public LazyDbKvState(kvStateId String, compact boolean, cons ShardedConnection, conf DbBackendConfig, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Parameter Type con : Connection to cons : ShardedConnection in method public LazyDbKvState(kvStateId String, compact boolean, cons ShardedConnection, conf DbBackendConfig, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V, nextId long) in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Return Type Connection to ShardedConnection in method public createShardedConnection() : ShardedConnection in class org.apache.flink.contrib.streaming.state.DbBackendConfig |
From |
To |
|
Change Return Type PreparedStatement to String in method public prepareKVCheckpointInsert(stateId String) : String in class org.apache.flink.contrib.streaming.state.DerbyAdapter |
From |
To |
|
Change Return Type PreparedStatement to String in method public prepareKVCheckpointInsert(stateId String) : String in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Change Return Type Connection to ShardedConnection in method public getConnections() : ShardedConnection in class org.apache.flink.contrib.streaming.state.DbStateBackend |
From |
To |
|
Change Return Type PreparedStatement to String in method public prepareKVCheckpointInsert(stateId String) : String in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Change Return Type PreparedStatement to String in method public prepareKeyLookup(stateId String) : String in class org.apache.flink.contrib.streaming.state.MySqlAdapter |
From |
To |
|
Change Return Type PreparedStatement to String in method public prepareKeyLookup(stateId String) : String in class org.apache.flink.contrib.streaming.state.DbAdapter |
From |
To |
|
Change Return Type MySqlAdapter to DbAdapter in method public getDbAdapter() : DbAdapter in class org.apache.flink.contrib.streaming.state.DbBackendConfig |
From |
To |
|
Change Attribute Type insertStatement : PreparedStatement to insertStatements : ShardedStatement in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Attribute Type dbAdapter : MySqlAdapter to dbAdapter : DbAdapter in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Attribute Type selectStatement : PreparedStatement to selectStatements : ShardedStatement in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Attribute Type con : Connection to connections : ShardedConnection in class org.apache.flink.contrib.streaming.state.DbStateBackend |
From |
To |
|
Change Attribute Type batchInsert : BatchInsert to batchInsert : BatchInserter in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Change Attribute Type dbAdapterClass : Class<? extends MySqlAdapter> to dbAdapter : DbAdapter in class org.apache.flink.contrib.streaming.state.DbBackendConfig |
From |
To |
|
Rename Parameter con : Connection to cons : ShardedConnection in method public LazyDbKvState(kvStateId String, compact boolean, cons ShardedConnection, conf DbBackendConfig, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V, nextId long) in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Rename Parameter recoveryTimestamp : long to nextCheckpointId : long in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot SimpleSlot, operatorState SerializedValue<StateHandle<?>>, nextCheckpointId long) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Rename Parameter recoceryTimestamp : long to nextCheckpointId : long in method public restoreState(state StreamTaskState, nextCheckpointId long) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Rename Parameter con : Connection to cons : ShardedConnection in method private initDB(cons ShardedConnection) : void in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |
|
Rename Parameter con : Connection to cons : ShardedConnection in method public LazyDbKvState(kvStateId String, compact boolean, cons ShardedConnection, conf DbBackendConfig, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) in class org.apache.flink.contrib.streaming.state.LazyDbKvState |
From |
To |