|
Change Variable Type nameToState : Map<String,List<Tuple2<StreamStateHandle,long[]>>> to nameToStateByMode : GroupByStateNameResults in method public repartitionState(previousParallelSubtaskStates List<OperatorStateHandle>, parallelism int) : List<Collection<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type offsMap : Map<String,long[]> to offsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method private doTestPartitionableStateRepartitioning(r Random, oldParallelism int, newParallelism int, numNamedStates int, maxPartitionsPerState int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type offsetsMap : Map<String,long[]> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method package closeAndGetHandle() : OperatorStateHandle in class org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream |
From |
To |
|
Change Variable Type offsetsMap : Map<String,long[]> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method private generateChainedPartitionableStateHandle(states Map<String,List<? extends Serializable>>) : ChainedStateHandle<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type entry : Map.Entry<String,long[]> to entry : Map.Entry<String,StateMetaInfo> in method public equals(o Object) : boolean in class org.apache.flink.runtime.state.OperatorStateHandle |
From |
To |
|
Change Variable Type entry : Map.Entry<String,long[]> to entry : Map.Entry<String,OperatorStateHandle.StateMetaInfo> in method private collectResult(opIdx int, operatorStateHandle OperatorStateHandle, resultCollector List<String>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type parallelOperatorState : List<Tuple2<StreamStateHandle,long[]>> to parallelOperatorState : List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>> in method private repartition(nameToStateByMode GroupByStateNameResults, parallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type offsetsMap : Map<String,long[]> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method public setUp() : void in class org.apache.flink.streaming.api.operators.StateInitializationContextImplTest |
From |
To |
|
Change Variable Type entry : Map.Entry<String,long[]> to entry : Map.Entry<String,StateMetaInfo> in method public hashCode() : int in class org.apache.flink.runtime.state.OperatorStateHandle |
From |
To |
|
Change Variable Type namedState : Map.Entry<String,long[]> to namedState : Map.Entry<String,OperatorStateHandle.StateMetaInfo> in method private doTestPartitionableStateRepartitioning(r Random, oldParallelism int, newParallelism int, numNamedStates int, maxPartitionsPerState int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type offsetsMap : Map<String,long[]> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method package createTaskStates(numTaskStates int, numSubtasksPerTask int) : Collection<TaskState> in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Test |
From |
To |
|
Change Variable Type e : Map.Entry<String,List<Tuple2<StreamStateHandle,long[]>>> to e : Map.Entry<String,List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>>> in method private repartition(nameToStateByMode GroupByStateNameResults, parallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type current : List<Tuple2<StreamStateHandle,long[]>> to current : List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>> in method private repartition(nameToStateByMode GroupByStateNameResults, parallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type partitionOffsetsMap : Map<String,long[]> to partitionOffsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method private serializeOperatorStateHandle(stateHandle OperatorStateHandle, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Change Variable Type e : Map.Entry<String,long[]> to e : Map.Entry<String,OperatorStateHandle.StateMetaInfo> in method private doTestPartitionableStateRepartitioning(r Random, oldParallelism int, newParallelism int, numNamedStates int, maxPartitionsPerState int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type handleWithOffsets : Tuple2<StreamStateHandle,long[]> to handleWithOffsets : Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo> in method private repartition(nameToStateByMode GroupByStateNameResults, parallelism int) : List<Map<StreamStateHandle,OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type namedStatesToOffsets : Map<String,long[]> to namedStatesToOffsets : Map<String,OperatorStateHandle.StateMetaInfo> in method private doTestPartitionableStateRepartitioning(r Random, oldParallelism int, newParallelism int, numNamedStates int, maxPartitionsPerState int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type nameToOffsets : Map.Entry<String,long[]> to nameToOffsets : Map.Entry<String,OperatorStateHandle.StateMetaInfo> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type e : Map.Entry<String,long[]> to e : Map.Entry<String,OperatorStateHandle.StateMetaInfo> in method private groupByStateName(previousParallelSubtaskStates List<OperatorStateHandle>) : GroupByStateNameResults in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type offsetsMap : Map<String,long[]> to offsetsMap : Map<String,OperatorStateHandle.StateMetaInfo> in method private deserializeOperatorStateHandle(dis DataInputStream) : OperatorStateHandle in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Change Variable Type writtenStatesMetaData : Map<String,long[]> to writtenStatesMetaData : Map<String,OperatorStateHandle.StateMetaInfo> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<OperatorStateHandle> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type stateLocations : List<Tuple2<StreamStateHandle,long[]>> to stateLocations : List<Tuple2<StreamStateHandle,OperatorStateHandle.StateMetaInfo>> in method private groupByStateName(previousParallelSubtaskStates List<OperatorStateHandle>) : GroupByStateNameResults in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type operatorStateMetadata : Map<String,long[]> to operatorStateMetadata : Map<String,OperatorStateHandle.StateMetaInfo> in method private createTask(taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type entry : Map.Entry<String,long[]> to entry : Map.Entry<String,OperatorStateHandle.StateMetaInfo> in method private serializeOperatorStateHandle(stateHandle OperatorStateHandle, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |