359b39c383347b14c1a3e382d59717ac1be1b222
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method private startKafkaTopology() : void renamed to public tupleTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type stream : DataStream<String> to stream : DataStream<Tuple2<Long,String>> in method public tupleTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Change Variable Type collector : Collector<String> to collector : Collector<Tuple2<Long,String>> in method public tupleTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Change Variable Type value : String to value : Tuple2<Long,String> in method public tupleTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To |