ed5ba95dee0c3aa4b8767313369778e7afce5155
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Attribute | 1 | ||
| Move Attribute private host : String from class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource to private host : String from class org.apache.flink.streaming.connectors.kafka.KafkaSimpleConsumerExample | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute host : String to hostName : String in class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter host : String to hostName : String in method public KafkaConsumerIterator(hostName String, port int, topic String, partition int, waitOnEmptyFetch long) in class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaConsumerIterator | From | To | |
| Rename Parameter host : String to hostName : String in method public SimpleKafkaSource(topic String, hostName String, port int, partition int, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource | From | To |