140bb0c66257d5d09d61845731aef1dbdb90a0bd
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type HashMap<StreamShardMetadata,SequenceNumber> to HashMap<StreamShardMetadata.EquivalenceWrapper,SequenceNumber> in method package getRestoredState() : HashMap<StreamShardMetadata.EquivalenceWrapper,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type entry : Map.Entry<StreamShardMetadata,SequenceNumber> to entry : Map.Entry<StreamShardMetadata.EquivalenceWrapper,SequenceNumber> in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type sequenceNumsToRestore : HashMap<StreamShardMetadata,SequenceNumber> to sequenceNumsToRestore : HashMap<StreamShardMetadata.EquivalenceWrapper,SequenceNumber> in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer | From | To |