a05b574cc68d3f652d11fece46c23bbc24f35430
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public testSnapshotStateShouldBeNullIfSourceNotOpened() : void renamed to public testSnapshotStateShouldNotClearListStateIfSourceNotOpened() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To | |
| Rename Method public testSnapshotStateShouldBeNullIfSourceNotRun() : void renamed to public testSnapshotStateShouldNotClearListStateIfSourceNotRun() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To | |
| Rename Variable | 1 | ||
| Rename Variable restored : Map.Entry<KinesisStreamShard,SequenceNumber> to shard : KinesisStreamShard in method public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Change Return Type | 1 | ||
| Change Return Type HashMap<KinesisStreamShard,SequenceNumber> to void in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Merge Parameter | 1 | ||
| Merge Parameter [checkpointId : long, checkpointTimestamp : long] to context : FunctionSnapshotContext in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type restored : Map.Entry<KinesisStreamShard,SequenceNumber> to shard : KinesisStreamShard in method public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Extract Method | 2 | ||
| Extract Method protected createFetcher(streams List<String>, sourceContext SourceFunction.SourceContext<T>, runtimeContext RuntimeContext, configProps Properties, deserializationSchema KinesisDeserializationSchema<T>) : KinesisDataFetcher<T> extracted from public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Extract Method private getFakeRestoredStore(streamName String) : HashMap<KinesisStreamShard,SequenceNumber> extracted from public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To |