7d294735eb3a77debbe2215c44dea4f97bcf7165
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Parameterize Variable | 1 | ||
| Parameterize Variable checkpointOffsets : long[] to offsets : long[] in method private setOffsetsInZooKeeper(offsets long[]) : void in class org.apache.flink.streaming.connectors.kafka.api.persistent.PersistentKafkaSource | From | To | |
| Extract Method | 1 | ||
| Extract Method private setOffsetsInZooKeeper(offsets long[]) : void extracted from public commitCheckpoint(checkpointId long) : void in class org.apache.flink.streaming.connectors.kafka.api.persistent.PersistentKafkaSource | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type pendingCheckpoints : Map<Long,long[]> to pendingCheckpoints : LinkedMap in class org.apache.flink.streaming.connectors.kafka.api.persistent.PersistentKafkaSource | From | To |