0b7c2db76fd25b5cde7c14c7eb906c308a4ecfb9
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Variable Type | 1 | ||
| Change Variable Type bttIterator : Iterator<Map.Entry<Node,SimpleConsumerThread<T>>> to bttIterator : Iterator<SimpleConsumerThread<T>> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, lastOffsets HashMap<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher | From | To |