|
Change Variable Type kinesisStreamShard : KinesisStreamShardV2 to kinesisStreamShard : StreamShardMetadata in method public testStreamShardMetadataAndHandleConversion() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type kinesisSequenceNumber : Tuple2<KinesisStreamShardV2,SequenceNumber> to kinesisSequenceNumber : Tuple2<StreamShardMetadata,SequenceNumber> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type tuple : Tuple2<KinesisStreamShardV2,SequenceNumber> to tuple : Tuple2<StreamShardMetadata,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type lastStateSnapshot : HashMap<KinesisStreamShardV2,SequenceNumber> to lastStateSnapshot : HashMap<StreamShardMetadata,SequenceNumber> in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type kinesisStreamShard : KinesisStreamShardV2 to kinesisStreamShard : StreamShardMetadata in method public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type entry : Map.Entry<KinesisStreamShardV2,SequenceNumber> to entry : Map.Entry<StreamShardMetadata,SequenceNumber> in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> to listState : TestingListState<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> to listState : TestingListState<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type typeInformation : TypeInformation<KinesisStreamShardV2> to typeInformation : TypeInformation<StreamShardMetadata> in method public testStreamShardMetadataSerializedUsingPojoSerializer() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type stateSnapshot : HashMap<KinesisStreamShardV2,SequenceNumber> to stateSnapshot : HashMap<StreamShardMetadata,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type expectedStateSnapshot : ArrayList<Tuple2<KinesisStreamShardV2,SequenceNumber>> to expectedStateSnapshot : ArrayList<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type stateSnapshot : HashMap<KinesisStreamShardV2,SequenceNumber> to stateSnapshot : HashMap<StreamShardMetadata,SequenceNumber> in method public snapshotState() : HashMap<StreamShardMetadata,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> to listState : TestingListState<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type kinesisStreamShardV2 : KinesisStreamShardV2 to streamShardMetadata : StreamShardMetadata in method public testLegacyKinesisStreamShardToStreamShardMetadataConversion() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> to listState : TestingListState<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testUseRestoredStateForSnapshotIfFetcherNotInitialized() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type state : Tuple2<KinesisStreamShardV2,SequenceNumber> to state : Tuple2<StreamShardMetadata,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type expectedState : HashMap<KinesisStreamShardV2,SequenceNumber> to expectedState : HashMap<StreamShardMetadata,SequenceNumber> in method public testRestoreFromFlink11() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerMigrationTest |
From |
To |
|
Change Variable Type kinesisStreamShardV2 : KinesisStreamShardV2 to streamShardMetadata : StreamShardMetadata in method public convertToStreamShardMetadata(streamShardHandle StreamShardHandle) : StreamShardMetadata in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type globalUnionState : List<Tuple2<KinesisStreamShardV2,SequenceNumber>> to globalUnionState : List<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testUseRestoredStateForSnapshotIfFetcherNotInitialized() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type other : KinesisStreamShardV2 to other : StreamShardMetadata in method public equals(obj Object) : boolean in class org.apache.flink.streaming.connectors.kinesis.model.StreamShardMetadata |
From |
To |
|
Change Variable Type initialState : ArrayList<Tuple2<KinesisStreamShardV2,SequenceNumber>> to initialState : ArrayList<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type state : Tuple2<KinesisStreamShardV2,SequenceNumber> to state : Tuple2<StreamShardMetadata,SequenceNumber> in method public testUseRestoredStateForSnapshotIfFetcherNotInitialized() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shardsStateTypeInfo : TypeInformation<Tuple2<KinesisStreamShardV2,SequenceNumber>> to shardsStateTypeInfo : TypeInformation<Tuple2<StreamShardMetadata,SequenceNumber>> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> to listState : TestingListState<Tuple2<StreamShardMetadata,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type currentState : Tuple2<KinesisStreamShardV2,SequenceNumber> to currentState : Tuple2<StreamShardMetadata,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |