a9e18fa921859319642085171289ea515008d572
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 5 | ||
| Extract Method package joinDiscoveryLoopThread() : void extracted from public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Extract Method private runWithPartitionDiscovery() : void extracted from public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Extract Method protected setupConsumer(consumer FlinkKafkaConsumerBase<String>) : void extracted from public testConfigureAutoCommitMode() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private createAndStartDiscoveryLoop(discoveryLoopErrorRef AtomicReference<Exception>) : void extracted from public run(sourceContext SourceContext<T>) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Extract Method protected setupConsumer(consumer FlinkKafkaConsumerBase<String>) : void extracted from public testConfigureDisableOffsetCommitWithoutCheckpointing() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To |