flink e5b65a7fc2b4a7532ca40748f81bcbf8ace46815

e5b65a7fc2b4a7532ca40748f81bcbf8ace46815

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 6

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Move And Inline Method	1
	Move And Inline Method public setIsRestoringFromFailure(bool boolean) : void moved from class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher to class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer & inlined to public run(sourceContext SourceContext<T>) : void	From	To
	Rename Variable	4
	Rename Variable snapShotState : ArrayList<Tuple2<KinesisStreamShard,SequenceNumber>> to expectedStateSnapshot : ArrayList<Tuple2<KinesisStreamShard,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Rename Variable runFetcherThread : Thread to consumerThread : Thread in method public testStreamToLastSeenShardStateIsCorrectlySetWhenNotRestoringFromFailure() : void in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcherTest	From	To
	Rename Variable newShardsCreatedWhileNotRunning : List<KinesisStreamShard> to allShards : List<KinesisStreamShard> in method public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer	From	To
	Rename Variable tuple : TypeInformation<Tuple2<KinesisStreamShard,SequenceNumber>> to shardsStateTypeInfo : TypeInformation<Tuple2<KinesisStreamShard,SequenceNumber>> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer	From	To
	Change Variable Type	9
	Change Variable Type currentState : Serializable to currentState : Tuple2<KinesisStreamShard,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Change Variable Type listState : TestingListState<Serializable> to listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Change Variable Type listState : TestingListState<Serializable> to listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Change Variable Type listState : TestingListState<Serializable> to listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> in method public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Change Variable Type listState : TestingListState<Serializable> to listState : TestingListState<Tuple2<KinesisStreamShard,SequenceNumber>> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Change Variable Type state : Serializable to state : Tuple2<KinesisStreamShard,SequenceNumber> in method public testListStateChangedAfterSnapshotState() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest	From	To
	Extract Variable	1
	Extract Variable fetcher : KinesisDataFetcher<T> in method public run(sourceContext SourceContext<T>) : void from class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer	From	To
	Inline Variable	1
	Inline Variable startingStateForNewShard : SequenceNumber in method public run(sourceContext SourceContext<T>) : void from class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer	From	To