b43067b68ad01882d061be49de8bdfa54a07bfd6
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 1 | ||
Change Parameter Type snapshotState : HashMap<KafkaTopicPartition,Long> to snapshotState : Map<KafkaTopicPartition,Long> in method public restoreOffsets(snapshotState Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher | From | To |