|
Change Parameter Type state : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> to state : List<Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>> in method public WrapperStateHandle(state List<Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>>) in class org.apache.flink.streaming.api.state.WrapperStateHandle |
From |
To |
|
Change Parameter Type snapshots : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> to snapshots : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in method public restoreInitialState(snapshots Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Parameter Type state : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> to state : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in method public restoreInitialState(state Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.StatefulStreamOperator |
From |
To |
|
Change Parameter Type snapshots : Map<Serializable,StateHandle<C>> to snapshots : StateHandle<Serializable> in method public restoreState(snapshots StateHandle<Serializable>) : void in class org.apache.flink.streaming.api.state.PartitionedStreamOperatorState |
From |
To |
|
Rename Variable restoredState : StreamOperatorState to restoredOpState : StreamOperatorState in method public restoreInitialState(snapshots Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Rename Variable handles : Map<Serializable,StateHandle<C>> to checkpoints : Map<Serializable,C> in method public snapshotStates(checkpointId long, checkpointTimestamp long) : StateHandle<Serializable> in class org.apache.flink.streaming.api.state.EagerStateStore |
From |
To |
|
Rename Variable handles : Map<Serializable,StateHandle<Serializable>> to checkpointHandle : StateHandle<Serializable> in method public restoreInitialState(snapshots Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Return Type Map<Serializable,StateHandle<C>> to StateHandle<Serializable> in method public snapshotState(checkpointId long, checkpointTimestamp long) : StateHandle<Serializable> in class org.apache.flink.streaming.api.state.StreamOperatorState |
From |
To |
|
Change Return Type StateHandleProvider<C> to StateHandleProvider<Serializable> in method protected getStateHandleProvider() : StateHandleProvider<Serializable> in class org.apache.flink.streaming.api.state.StreamOperatorState |
From |
To |
|
Change Return Type Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> to Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Return Type Map<Serializable,StateHandle<C>> to StateHandle<Serializable> in method public snapshotState(checkpointId long, checkpointTimestamp long) : StateHandle<Serializable> in class org.apache.flink.streaming.api.state.PartitionedStreamOperatorState |
From |
To |
|
Change Return Type Map<Serializable,StateHandle<C>> to StateHandle<Serializable> in method public snapshotStates(checkpointId long, checkpointTimestamp long) : StateHandle<Serializable> in class org.apache.flink.streaming.api.state.EagerStateStore |
From |
To |
|
Change Return Type Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> to Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.StatefulStreamOperator |
From |
To |
|
Change Return Type Map<Serializable,StateHandle<C>> to StateHandle<Serializable> in method public snapshotStates(checkpointId long, checkpointTimestamp long) : StateHandle<Serializable> in class org.apache.flink.streaming.api.state.PartitionedStateStore |
From |
To |
|
Change Variable Type operatorStateSnapshots : Map<String,PartitionedStateHandle> to operatorStateSnapshots : Map<String,OperatorStateHandle> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Variable Type handles : Map<Serializable,StateHandle<C>> to checkpoints : Map<Serializable,C> in method public snapshotStates(checkpointId long, checkpointTimestamp long) : StateHandle<Serializable> in class org.apache.flink.streaming.api.state.EagerStateStore |
From |
To |
|
Change Variable Type handles : Map<Serializable,StateHandle<Serializable>> to checkpointHandle : StateHandle<Serializable> in method public restoreInitialState(snapshots Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Variable Type snapshot : Entry<String,PartitionedStateHandle> to snapshot : Entry<String,OperatorStateHandle> in method public restoreInitialState(snapshots Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Variable Type chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>> in method public setInitialState(stateHandle StateHandle<Serializable>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type snapshots : Map<String,PartitionedStateHandle> to snapshots : Map<String,OperatorStateHandle> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Variable Type state : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> to state : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in method public setInitialState(stateHandle StateHandle<Serializable>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>> in method public triggerCheckpoint(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>>> in method public discardState() : void in class org.apache.flink.streaming.api.state.WrapperStateHandle |
From |
To |
|
Change Variable Type state : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> to state : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in method public discardState() : void in class org.apache.flink.streaming.api.state.WrapperStateHandle |
From |
To |