9ed9b68397b51bfd2b0f6e532212a82f771641bd
Files Diff
- Added: 6
- Removed: 0
- Renamed: 0
- Modified: 25
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 8 | ||
| Change Parameter Type partitioner : KafkaPartitioner<T> to partitioner : FlinkKafkaPartitioner<T> in method public abstract getProducerSink(topic String, serSchema KeyedSerializationSchema<T>, props Properties, partitioner FlinkKafkaPartitioner<T>) : StreamSink<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment | From | To | |
| Change Parameter Type partitioner : KafkaPartitioner<T> to partitioner : FlinkKafkaPartitioner<T> in method public produceIntoKafka(stream DataStream<T>, topic String, serSchema KeyedSerializationSchema<T>, props Properties, partitioner FlinkKafkaPartitioner<T>) : DataStreamSink<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl | From | To | |
| Change Parameter Type partitioner : KafkaPartitioner<T> to partitioner : FlinkKafkaPartitioner<T> in method public getProducerSink(topic String, serSchema KeyedSerializationSchema<T>, props Properties, partitioner FlinkKafkaPartitioner<T>) : StreamSink<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl | From | To | |
| Change Parameter Type partitioner : KafkaPartitioner<T> to partitioner : FlinkKafkaPartitioner<T> in method public abstract produceIntoKafka(stream DataStream<T>, topic String, serSchema KeyedSerializationSchema<T>, props Properties, partitioner FlinkKafkaPartitioner<T>) : DataStreamSink<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment | From | To | |
| Move Attribute | 1 | ||
| Move Attribute protected partitions : int[] from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase to private partitions : int[] from class org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaDelegatePartitioner | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner from classes [org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase.CustomPartitioner] | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute partitioner : KafkaPartitioner<IN> to flinkKafkaPartitioner : FlinkKafkaPartitioner in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type partitioner : KafkaPartitioner<IN> to flinkKafkaPartitioner : FlinkKafkaPartitioner in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase | From | To | |
| Change Attribute Type partitioner : KafkaPartitioner<Row> to partitioner : FlinkKafkaPartitioner<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSink | From | To | |
| Extract Method | 1 | ||
| Extract Method protected getPartitionsByTopic(topic String, producer KafkaProducer<byte[],byte[]>) : int[] extracted from public open(configuration Configuration) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase | From | To |