3a8717fd6e569a7b91d4265de109663a6c53d7ab
Files Diff
- Added: 4
- Removed: 1
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.connectors.kafka.internals.ZooKeeperStringSerializer moved to org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer | From | To | |
| Extract Variable | 5 | ||
| Extract Variable producerProperties : Properties in method public runSimpleConcurrentProducerConsumerTopology() : void from class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Extract Variable producerProperties : Properties in method protected writeSequence(env StreamExecutionEnvironment, topicName String, numElements int, parallelism int) : void from class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Extract Variable producerProperties : Properties in method public runKeyValueTest() : void from class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Extract Variable producerProperties : Properties in method public run() : void from class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator | From | To | |
| Extract Variable producerProperties : Properties in method public runAllDeletesTest() : void from class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To |