3655200799929409352945a3f4fce0f3e987b9ad
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable toCommit : Map<TopicPartition,OffsetAndMetadata> to commitOffsetsAndCallback : Tuple2<Map<TopicPartition,OffsetAndMetadata>,KafkaCommitCallback> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type toCommit : Map<TopicPartition,OffsetAndMetadata> to commitOffsetsAndCallback : Tuple2<Map<TopicPartition,OffsetAndMetadata>,KafkaCommitCallback> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type nextOffsetsToCommit : AtomicReference<Map<TopicPartition,OffsetAndMetadata>> to nextOffsetsToCommit : AtomicReference<Tuple2<Map<TopicPartition,OffsetAndMetadata>,KafkaCommitCallback>> in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread | From | To |