97ad55f1d89839dc9df0066540b5fbc260ea3f4a
Files Diff
- Added: 4
- Removed: 2
- Renamed: 0
- Modified: 7
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.connectors.kafka.KafkaSink renamed to org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute config : ProducerConfig to producerConfig : Properties in method public open(configuration Configuration) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.connectors.kafka.partitioner.KafkaPartitioner from classes [org.apache.flink.streaming.connectors.kafka.KafkaProducerITCase.CustomPartitioner, org.apache.flink.streaming.connectors.kafka.testutils.Tuple2Partitioner] | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type producer : KafkaSink<String> to producer : FlinkKafkaProducer<String> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator | From | To | |
| Change Variable Type config : ProducerConfig to producerConfig : Properties in method public open(configuration Configuration) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type producer : Producer<IN,byte[]> to producer : KafkaProducer<byte[],byte[]> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer | From | To | |
| Change Attribute Type partitioner : SerializableKafkaPartitioner to partitioner : KafkaPartitioner in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer | From | To |