9ee8f42547f903b214d8262f81c4d62ee70a4525
Files Diff
- Added: 13
- Removed: 3
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.connectors.kafka.KafkaSource moved to org.apache.flink.streaming.connectors.kafka.api.KafkaSource | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute it : ConsumerIterator<byte[],byte[]> to consumerIterator : ConsumerIterator<byte[],byte[]> in method public invoke(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.kafka.api.KafkaSource | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute zkQuorum : String to zookeeperHost : String in class org.apache.flink.streaming.connectors.kafka.api.KafkaSource | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter zkQuorum : String to zookeeperHost : String in method public KafkaSource(zookeeperHost String, topicId String, deserializationSchema DeserializationSchema<OUT>, zookeeperSyncTimeMillis long) in class org.apache.flink.streaming.connectors.kafka.api.KafkaSource | From | To |