57ffddedd0e4edf3b7c55405aca7130f5a32fe4a
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 16
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 1 | ||
| Extract Method protected setKafkaConsumerOffset(startupMode StartupMode, consumer FlinkKafkaConsumerBase<Tuple2<Integer,Integer>>, specificStartupOffsets Map<KafkaTopicPartition,Long>, specificStartupDate Date) : void extracted from protected readSequence(env StreamExecutionEnvironment, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>, cc Properties, topicName String, partitionsToValuesCountAndStartOffset Map<Integer,Tuple2<Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To |