09aa841d6b0b7ee407c8011f35ec7c6a274480a3
Files Diff
- Added: 2
- Removed: 2
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 1 | ||
Rename Method public invoke(collector Collector<OUT>) : void renamed to public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource | From | To | |
Rename Class | 1 | ||
Rename Class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicCreator renamed to org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicFactory | From | To | |
Rename Parameter | 1 | ||
Rename Parameter veretxName : Integer to vertexName : Integer in method public addOperatorState(vertexName Integer, stateName String, state OperatorState<?>) : void in class org.apache.flink.streaming.api.StreamGraph | From | To |