|
Change Parameter Type shard : KinesisStreamShard to shard : StreamShardHandle in method public getShardIterator(shard StreamShardHandle, shardIteratorType String, startingMarker Object) : String in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.SingleShardEmittingFixNumOfRecordsWithExpiredIteratorKinesis |
From |
To |
|
Change Parameter Type subscribedShard : KinesisStreamShard to subscribedShard : StreamShardHandle in method protected ShardConsumer(fetcherRef KinesisDataFetcher<T>, subscribedShardStateIndex Integer, subscribedShard StreamShardHandle, lastSequenceNum SequenceNumber, kinesis KinesisProxyInterface) in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer |
From |
To |
|
Change Parameter Type kinesisStreamShard : KinesisStreamShard to kinesisStreamShard : KinesisStreamShardV2 in method public KinesisStreamShardState(kinesisStreamShard KinesisStreamShardV2, streamShardHandle StreamShardHandle, lastProcessedSequenceNum SequenceNumber) in class org.apache.flink.streaming.connectors.kinesis.model.KinesisStreamShardState |
From |
To |
|
Change Parameter Type shard : KinesisStreamShard to shard : StreamShardHandle in method public getShardIterator(shard StreamShardHandle, shardIteratorType String, startingMarker Object) : String in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Change Parameter Type retrievedShards : List<KinesisStreamShard> to retrievedShards : List<StreamShardHandle> in method public addRetrievedShardsToStream(stream String, retrievedShards List<StreamShardHandle>) : void in class org.apache.flink.streaming.connectors.kinesis.proxy.GetShardListResult |
From |
To |
|
Change Parameter Type subscribedShard : KinesisStreamShard to subscribedShard : StreamShardHandle in method public ShardConsumer(fetcherRef KinesisDataFetcher<T>, subscribedShardStateIndex Integer, subscribedShard StreamShardHandle, lastSequenceNum SequenceNumber) in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer |
From |
To |
|
Change Parameter Type shard : KinesisStreamShard to shard : StreamShardHandle in method public getShardIterator(shard StreamShardHandle, shardIteratorType String, startingMarker Object) : String in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |
|
Change Parameter Type shard : KinesisStreamShard to shard : StreamShardHandle in method public getShardIterator(shard StreamShardHandle, shardIteratorType String, startingMarker Object) : String in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxyInterface |
From |
To |
|
Change Parameter Type shard : KinesisStreamShard to shard : StreamShardHandle in method public isThisSubtaskShouldSubscribeTo(shard StreamShardHandle, totalNumberOfConsumerSubtasks int, indexOfThisConsumerSubtask int) : boolean in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Parameter Type retrievedShard : KinesisStreamShard to retrievedShard : StreamShardHandle in method public addRetrievedShardToStream(stream String, retrievedShard StreamShardHandle) : void in class org.apache.flink.streaming.connectors.kinesis.proxy.GetShardListResult |
From |
To |
|
Change Parameter Type shard : KinesisStreamShard to shard : StreamShardHandle in method public getShardIterator(shard StreamShardHandle, shardIteratorType String, startingMarker Object) : String in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.SingleShardEmittingFixNumOfRecordsKinesis |
From |
To |
|
Change Variable Type lastStateSnapshot : HashMap<KinesisStreamShard,SequenceNumber> to lastStateSnapshot : HashMap<KinesisStreamShardV2,SequenceNumber> in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type state : Tuple2<KinesisStreamShard,SequenceNumber> to state : Tuple2<KinesisStreamShardV2,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type newShard : KinesisStreamShard to newShard : StreamShardHandle in method public discoverNewShardsToSubscribe() : List<StreamShardHandle> in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type fakeRestoredState : HashMap<KinesisStreamShard,SequenceNumber> to fakeRestoredState : HashMap<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromLegacyCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type tuple : Tuple2<KinesisStreamShard,SequenceNumber> to tuple : Tuple2<KinesisStreamShardV2,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredShard : Map.Entry<KinesisStreamShard,SequenceNumber> to restoredShard : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredState : Map.Entry<KinesisStreamShard,String> to restoredState : Map.Entry<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNoNewShardsSinceRestoredCheckpointAndSomeStreamsDoNotExist() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type initialState : ArrayList<Tuple2<KinesisStreamShard,SequenceNumber>> to initialState : ArrayList<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> to listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shards : List<KinesisStreamShard> to shards : List<StreamShardHandle> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type streamsWithShards : Map.Entry<String,List<KinesisStreamShard>> to streamsWithShards : Map.Entry<String,List<StreamShardHandle>> in method public getShardList(streamNamesWithLastSeenShardIds Map<String,String>) : GetShardListResult in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |
|
Change Variable Type newShardsOfStream : List<KinesisStreamShard> to newShardsOfStream : List<StreamShardHandle> in method public discoverNewShardsToSubscribe() : List<StreamShardHandle> in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type fakeToBeConsumedShard : KinesisStreamShard to fakeToBeConsumedShard : StreamShardHandle in method public testCorrectNumOfCollectedRecordsAndUpdatedStateWithUnexpectedExpiredIterator() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerTest |
From |
To |
|
Change Variable Type expectedState : HashMap<KinesisStreamShard,SequenceNumber> to expectedState : HashMap<KinesisStreamShardV2,SequenceNumber> in method public testRestoreFromFlink11() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerMigrationTest |
From |
To |
|
Change Variable Type globalUnionState : List<Tuple2<KinesisStreamShard,SequenceNumber>> to globalUnionState : List<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testUseRestoredStateForSnapshotIfFetcherNotInitialized() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shard : KinesisStreamShard to shard : StreamShardHandle in method public noShardsFoundForRequestedStreamsBehaviour() : KinesisProxyInterface in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory |
From |
To |
|
Change Variable Type fakeRestoredState : HashMap<KinesisStreamShard,SequenceNumber> to fakeRestoredState : HashMap<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type stateSnapshot : HashMap<KinesisStreamShard,SequenceNumber> to stateSnapshot : HashMap<KinesisStreamShardV2,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredStateUnderTest : Map<KinesisStreamShard,String> to restoredStateUnderTest : Map<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNoNewShardsSinceRestoredCheckpointAndSomeStreamsDoNotExist() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type restoredState : Map.Entry<KinesisStreamShard,String> to restoredState : Map.Entry<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNewShardsFoundSinceRestoredCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type state : Map.Entry<KinesisStreamShard,SequenceNumber> to state : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type newShardsToSubscribe : List<KinesisStreamShard> to newShardsToSubscribe : List<StreamShardHandle> in method public discoverNewShardsToSubscribe() : List<StreamShardHandle> in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type state : Map.Entry<KinesisStreamShard,SequenceNumber> to state : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type allShards : List<KinesisStreamShard> to allShards : List<StreamShardHandle> in method public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type shardsStateTypeInfo : TypeInformation<Tuple2<KinesisStreamShard,SequenceNumber>> to shardsStateTypeInfo : TypeInformation<Tuple2<KinesisStreamShardV2,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<KinesisStreamShard,SequenceNumber>> to listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testUseRestoredStateForSnapshotIfFetcherNotInitialized() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredShard : Map.Entry<KinesisStreamShard,SequenceNumber> to restoredShard : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type fakeRestoredState : HashMap<KinesisStreamShard,SequenceNumber> to fakeRestoredState : HashMap<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type stateSnapshot : HashMap<KinesisStreamShard,SequenceNumber> to stateSnapshot : HashMap<KinesisStreamShardV2,SequenceNumber> in method public snapshotState() : HashMap<KinesisStreamShardV2,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type shards : List<KinesisStreamShard> to shards : List<StreamShardHandle> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromLegacyCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type newShardsDueToResharding : List<KinesisStreamShard> to newShardsDueToResharding : List<StreamShardHandle> in method public runFetcher() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type shardsOfStream : List<KinesisStreamShard> to shardsOfStream : List<StreamShardHandle> in method public NonReshardedStreamsKinesis(streamsToShardCount Map<String,Integer>) in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |
|
Change Variable Type shard : KinesisStreamShard to shard : StreamShardHandle in method public getShardList(streamNamesWithLastSeenShardIds Map<String,String>) : GetShardListResult in class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |
|
Change Variable Type restoredState : Map.Entry<KinesisStreamShard,String> to restoredState : Map.Entry<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNewShardsFoundSinceRestoredCheckpointAndSomeStreamsDoNotExist() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type currentState : Tuple2<KinesisStreamShard,SequenceNumber> to currentState : Tuple2<KinesisStreamShardV2,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shard : KinesisStreamShard to shard : StreamShardHandle in method public runFetcher() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Variable Type restoredStateUnderTest : Map<KinesisStreamShard,String> to restoredStateUnderTest : Map<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNewShardsFoundSinceRestoredCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type state : Map.Entry<KinesisStreamShard,SequenceNumber> to state : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredState : Map.Entry<KinesisStreamShard,String> to restoredState : Map.Entry<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNoNewShardsSinceRestoredCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type shard : KinesisStreamShard to shard : StreamShardHandle in method public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type state : Tuple2<KinesisStreamShard,SequenceNumber> to state : Tuple2<KinesisStreamShardV2,SequenceNumber> in method public testUseRestoredStateForSnapshotIfFetcherNotInitialized() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type fakeRestoredStateForOthers : HashMap<KinesisStreamShard,SequenceNumber> to fakeRestoredStateForOthers : HashMap<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type expectedStateSnapshot : ArrayList<Tuple2<KinesisStreamShard,SequenceNumber>> to expectedStateSnapshot : ArrayList<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredShard : Map.Entry<KinesisStreamShard,SequenceNumber> to restoredShard : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromLegacyCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type fakeToBeConsumedShard : KinesisStreamShard to fakeToBeConsumedShard : StreamShardHandle in method public testCorrectNumOfCollectedRecordsAndUpdatedState() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> to listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type fakeRestoredState : HashMap<KinesisStreamShard,SequenceNumber> to fakeRestoredState : HashMap<StreamShardHandle,SequenceNumber> in method private getFakeRestoredStore(streamName String) : HashMap<StreamShardHandle,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredStateUnderTest : Map<KinesisStreamShard,String> to restoredStateUnderTest : Map<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNewShardsFoundSinceRestoredCheckpointAndSomeStreamsDoNotExist() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type fakeRestoredState : HashMap<KinesisStreamShard,SequenceNumber> to fakeRestoredState : HashMap<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type entry : Map.Entry<KinesisStreamShard,SequenceNumber> to entry : Map.Entry<KinesisStreamShardV2,SequenceNumber> in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type restoredStateUnderTest : Map<KinesisStreamShard,String> to restoredStateUnderTest : Map<StreamShardHandle,String> in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNoNewShardsSinceRestoredCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> to listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shards : List<KinesisStreamShard> to shards : List<StreamShardHandle> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shards : List<KinesisStreamShard> to shards : List<StreamShardHandle> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> to listState : TestingListState<Tuple2<KinesisStreamShardV2,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type restoredShard : Map.Entry<KinesisStreamShard,SequenceNumber> to restoredShard : Map.Entry<StreamShardHandle,SequenceNumber> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type shardsOfStream : List<KinesisStreamShard> to shardsOfStream : List<StreamShardHandle> in method private getShardsOfStream(streamName String, lastSeenShardId String) : List<StreamShardHandle> in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Change Variable Type kinesisSequenceNumber : Tuple2<KinesisStreamShard,SequenceNumber> to kinesisSequenceNumber : Tuple2<KinesisStreamShardV2,SequenceNumber> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |