|
Change Parameter Type lastSequenceNums : HashMap<KinesisStreamShard,String> to lastSequenceNums : HashMap<KinesisStreamShard,SequenceNumber> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializationSchema KinesisDeserializationSchema<T>, lastSequenceNums HashMap<KinesisStreamShard,SequenceNumber>) : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Parameter Type lastSequenceNum : String to lastSequenceNum : SequenceNumber in method private getDummyShardConsumerThreadWithMockedKinesisProxy(dummySourceContext SourceFunction.SourceContext<String>, kinesisProxyMock KinesisProxy, owningFetcherRefMock KinesisDataFetcher, testConsumerConfig Properties, assignedShard KinesisStreamShard, lastSequenceNum SequenceNumber, seqNumState HashMap<KinesisStreamShard,SequenceNumber>) : ShardConsumerThread in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThreadTest |
From |
To |
|
Change Parameter Type seqNumState : HashMap<KinesisStreamShard,String> to seqNumState : HashMap<KinesisStreamShard,SequenceNumber> in method public ShardConsumerThread(ownerRef KinesisDataFetcher, props Properties, assignedShard KinesisStreamShard, lastSequenceNum SequenceNumber, sourceContext SourceFunction.SourceContext<T>, deserializer KinesisDeserializationSchema<T>, seqNumState HashMap<KinesisStreamShard,SequenceNumber>) in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThread |
From |
To |
|
Change Parameter Type lastSequenceNum : String to lastSequenceNum : SequenceNumber in method public ShardConsumerThread(ownerRef KinesisDataFetcher, props Properties, assignedShard KinesisStreamShard, lastSequenceNum SequenceNumber, sourceContext SourceFunction.SourceContext<T>, deserializer KinesisDeserializationSchema<T>, seqNumState HashMap<KinesisStreamShard,SequenceNumber>) in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThread |
From |
To |
|
Change Parameter Type sequenceNum : String to sequenceNum : SequenceNumber in method public advanceSequenceNumberTo(streamShard KinesisStreamShard, sequenceNum SequenceNumber) : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Parameter Type seqNumState : HashMap<KinesisStreamShard,String> to seqNumState : HashMap<KinesisStreamShard,SequenceNumber> in method private getDummyShardConsumerThreadWithMockedKinesisProxy(dummySourceContext SourceFunction.SourceContext<String>, kinesisProxyMock KinesisProxy, owningFetcherRefMock KinesisDataFetcher, testConsumerConfig Properties, assignedShard KinesisStreamShard, lastSequenceNum SequenceNumber, seqNumState HashMap<KinesisStreamShard,SequenceNumber>) : ShardConsumerThread in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThreadTest |
From |
To |
|
Change Parameter Type restoredState : HashMap<KinesisStreamShard,String> to restoredState : HashMap<KinesisStreamShard,SequenceNumber> in method public restoreState(restoredState HashMap<KinesisStreamShard,SequenceNumber>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type fakeRestoredState : HashMap<KinesisStreamShard,String> to fakeRestoredState : HashMap<KinesisStreamShard,SequenceNumber> in method public testOpenWithRestoreStateFetcherAdvanceToCorrespondingSequenceNumbers() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type seqNumState : HashMap<KinesisStreamShard,String> to seqNumState : HashMap<KinesisStreamShard,SequenceNumber> in method public testAllRecordsFetchedFromKinesisAreCorrectlyCollected() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThreadTest |
From |
To |
|
Change Variable Type restoreSequenceNo : Map.Entry<KinesisStreamShard,String> to restoreSequenceNo : Map.Entry<KinesisStreamShard,SequenceNumber> in method public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type restoreSequenceNum : Map.Entry<KinesisStreamShard,String> to restoreSequenceNum : Map.Entry<KinesisStreamShard,SequenceNumber> in method public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type currentSequenceNums : HashMap<KinesisStreamShard,String> to currentSequenceNums : HashMap<KinesisStreamShard,SequenceNumber> in method public snapshotState(checkpointId long, checkpointTimestamp long) : HashMap<KinesisStreamShard,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Variable Type listOfSeqNumIfAssignedShards : ArrayList<String> to listOfSeqNumOfAssignedShards : ArrayList<SequenceNumber> in method public testOpenWithRestoreStateFetcherAdvanceToCorrespondingSequenceNumbers() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest |
From |
To |
|
Change Variable Type record : Record to record : UserRecord in method public run() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThread |
From |
To |
|
Change Variable Type assignedShard : Map.Entry<KinesisStreamShard,String> to assignedShard : Map.Entry<KinesisStreamShard,SequenceNumber> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializationSchema KinesisDeserializationSchema<T>, lastSequenceNums HashMap<KinesisStreamShard,SequenceNumber>) : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Attribute Type lastSequenceNums : HashMap<KinesisStreamShard,String> to lastSequenceNums : HashMap<KinesisStreamShard,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |
|
Change Attribute Type lastSequenceNum : String to lastSequenceNum : SequenceNumber in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThread |
From |
To |
|
Change Attribute Type seqNoState : HashMap<KinesisStreamShard,String> to seqNoState : HashMap<KinesisStreamShard,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerThread |
From |
To |
|
Change Attribute Type assignedShardsWithStartingSequenceNum : HashMap<KinesisStreamShard,String> to assignedShardsWithStartingSequenceNum : HashMap<KinesisStreamShard,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |
|
Change Attribute Type sequenceNumsToRestore : HashMap<KinesisStreamShard,String> to sequenceNumsToRestore : HashMap<KinesisStreamShard,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer |
From |
To |