e3fcbb087568a33aa03f58ba0dc359b1a6b02bfd
Files Diff
- Added: 0
- Removed: 4
- Renamed: 0
- Modified: 19
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method protected createTableSinkWithFlinkPartitioner(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>, kafkaProducer FlinkKafkaProducerBase<Row>) : KafkaTableSink renamed to protected createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>, kafkaProducer FlinkKafkaProducerBase<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSinkTest | From | To | |
| Rename Method protected createTableSinkWithFlinkPartitioner(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>, kafkaProducer FlinkKafkaProducerBase<Row>) : KafkaTableSink renamed to protected createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>, kafkaProducer FlinkKafkaProducerBase<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSinkTest | From | To | |
| Rename Method public testPartitionerOpenedWithDeterminatePartitionList() : void renamed to public testPartitionerInvokedWithDeterminatePartitionList() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBaseTest | From | To | |
| Rename Method protected abstract createTableSinkWithFlinkPartitioner(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>, kafkaProducer FlinkKafkaProducerBase<Row>) : KafkaTableSink renamed to protected abstract createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>, kafkaProducer FlinkKafkaProducerBase<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkTestBase | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type partitioner : KafkaPartitioner to partitioner : FlinkKafkaPartitioner in method package DummyFlinkKafkaProducer(producerConfig Properties, schema KeyedSerializationSchema<T>, partitioner FlinkKafkaPartitioner) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBaseTest.DummyFlinkKafkaProducer | From | To | |
| Change Parameter Type expectedPartitions : int to expectedTopicsToNumPartitions : Map<String,Integer> in method public CustomPartitioner(expectedTopicsToNumPartitions Map<String,Integer>) in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase.CustomPartitioner | From | To | |
| Rename Variable | 3 | ||
| Rename Variable parallelism : int to dynamicTopicPartitions : int in method public runCustomPartitioningTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase | From | To | |
| Rename Variable source : FlinkKafkaConsumerBase<Tuple2<Long,String>> to defaultTopicSource : FlinkKafkaConsumerBase<Tuple2<Long,String>> in method public runCustomPartitioningTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase | From | To | |
| Rename Variable topic : String to defaultTopic : String in method public runCustomPartitioningTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute expectedPartitions : int to expectedTopicsToNumPartitions : Map<String,Integer> in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase.CustomPartitioner | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type expectedPartitions : int to expectedTopicsToNumPartitions : Map<String,Integer> in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase.CustomPartitioner | From | To | |
| Change Attribute Type PARTITIONER : KafkaPartitioner<Row> to PARTITIONER : FlinkKafkaPartitioner<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkTestBase | From | To | |
| Change Attribute Type flinkKafkaPartitioner : FlinkKafkaPartitioner to flinkKafkaPartitioner : FlinkKafkaPartitioner<IN> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter expectedPartitions : int to expectedTopicsToNumPartitions : Map<String,Integer> in method public CustomPartitioner(expectedTopicsToNumPartitions Map<String,Integer>) in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase.CustomPartitioner | From | To | |
| Rename Parameter next : Row to record : Row in method public partition(record Row, key byte[], value byte[], targetTopic String, partitions int[]) : int in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkTestBase.CustomPartitioner | From | To |