57b3cde863922094be4f395063317e42349aedb3
Files Diff
- Added: 14
- Removed: 10
- Renamed: 0
- Modified: 19
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 2 | ||
| Rename Variable params : DescriptorProperties to descriptorProperties : DescriptorProperties in method private getValidatedProperties(properties Map<String,String>) : DescriptorProperties in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Rename Variable params : DescriptorProperties to descriptorProperties : DescriptorProperties in method public createStreamTableSource(properties Map<String,String>) : StreamTableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Change Return Type | 1 | ||
| Change Return Type FlinkKafkaProducerBase<Row> to SinkFunction<Row> in method protected abstract createKafkaProducer(topic String, properties Properties, serializationSchema SerializationSchema<Row>, partitioner FlinkKafkaPartitioner<Row>) : SinkFunction<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSink | From | To | |
| Rename Class | 10 | ||
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceFactory renamed to org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactory | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceFactory renamed to org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactory | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceFactoryTest renamed to org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactoryTest | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceFactory renamed to org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactory | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory renamed to org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceFactoryTest renamed to org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactoryTest | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactoryTestBase renamed to org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceFactoryTest renamed to org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactoryTest | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceFactory renamed to org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactory | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceFactoryTest renamed to org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactoryTest | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute offsets : Map<Integer,Long> to OFFSETS : Map<Integer,Long> in method public testTableSource() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute function : SourceFunction<?> to sourceFunction : SourceFunction<?> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase.StreamExecutionEnvironmentMock | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type kafkaProducer : FlinkKafkaProducerBase<Row> to kafkaProducer : SinkFunction<Row> in method public emitDataStream(dataStream DataStream<Row>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSink | From | To | |
| Change Variable Type formatFactory : DeserializationSchemaFactory<?> to formatFactory : DeserializationSchemaFactory<Row> in method private getDeserializationSchema(properties Map<String,String>) : DeserializationSchema<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Extract Method | 4 | ||
| Extract Method private getStartupOptions(descriptorProperties DescriptorProperties, topic String) : StartupOptions extracted from public createStreamTableSource(properties Map<String,String>) : StreamTableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Extract Method private getKafkaProperties(descriptorProperties DescriptorProperties) : Properties extracted from public createStreamTableSource(properties Map<String,String>) : StreamTableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Extract Method private getDeserializationSchema(properties Map<String,String>) : DeserializationSchema<Row> extracted from public createStreamTableSource(properties Map<String,String>) : StreamTableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Extract Method private getValidatedProperties(properties Map<String,String>) : DescriptorProperties extracted from public createStreamTableSource(properties Map<String,String>) : StreamTableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type serializationSchema : SerializationSchema<Row> to serializationSchema : Optional<SerializationSchema<Row>> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSink | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter function : SourceFunction<OUT> to sourceFunction : SourceFunction<OUT> in method public addSource(sourceFunction SourceFunction<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase.StreamExecutionEnvironmentMock | From | To |