|
Change Parameter Type state : Map<String,PartitionedStateHandle> to state : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public restoreInitialState(state Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>) : void in class org.apache.flink.streaming.api.operators.StatefulStreamOperator |
From |
To |
|
Change Parameter Type snapshots : Map<String,PartitionedStateHandle> to snapshots : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public restoreInitialState(snapshots Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Parameter Type state : List<Map<String,PartitionedStateHandle>> to state : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> in method public WrapperStateHandle(state List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>>) in class org.apache.flink.streaming.api.state.WrapperStateHandle |
From |
To |
|
Change Return Type Map<String,PartitionedStateHandle> to Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Return Type Map<String,PartitionedStateHandle> to Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in class org.apache.flink.streaming.api.operators.StatefulStreamOperator |
From |
To |
|
Change Variable Type stateMap : Map<String,PartitionedStateHandle> to state : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public discardState() : void in class org.apache.flink.streaming.api.state.WrapperStateHandle |
From |
To |
|
Change Variable Type chainedStates : List<Map<String,PartitionedStateHandle>> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> in method public discardState() : void in class org.apache.flink.streaming.api.state.WrapperStateHandle |
From |
To |
|
Change Variable Type chainedStates : List<Map<String,PartitionedStateHandle>> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> 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<Serializable> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> in method public setInitialState(stateHandle StateHandle<Serializable>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type chainedStates : List<Map<String,PartitionedStateHandle>> to chainedStates : List<Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>>> in method public confirmCheckpoint(checkpointId long, stateHandle SerializedValue<StateHandle<?>>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type chainedState : Map<String,PartitionedStateHandle> to chainedState : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public confirmCheckpoint(checkpointId long, stateHandle SerializedValue<StateHandle<?>>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type state : Serializable to state : Tuple2<StateHandle<Serializable>,Map<String,PartitionedStateHandle>> in method public setInitialState(stateHandle StateHandle<Serializable>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |