ee40335ffa40fb32a692fa6be70946d9a70301b2
Files Diff
- Added: 32
- Removed: 20
- Renamed: 0
- Modified: 63
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Pull Up Method | 4 | ||
| Pull Up Method public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka09TableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Pull Up Method public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka011TableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Pull Up Method public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka08TableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Pull Up Method public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka010TableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type schemaType : TypeInformation<?> to schemaType : TypeInformation<Row> in method public schema(schemaType TypeInformation<Row>) : Json in class org.apache.flink.table.descriptors.Json | From | To | |
| Move Method | 4 | ||
| Move Method public hashCode() : int from class org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource to public hashCode() : int from class org.apache.flink.formats.avro.AvroRowDeserializationSchema | From | To | |
| Move Method public equals(o Object) : boolean from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource to public equals(o Object) : boolean from class org.apache.flink.formats.json.JsonRowDeserializationSchema | From | To | |
| Move Method public equals(o Object) : boolean from class org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource to public equals(o Object) : boolean from class org.apache.flink.formats.avro.AvroRowDeserializationSchema | From | To | |
| Move Method public hashCode() : int from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource to public hashCode() : int from class org.apache.flink.formats.avro.AvroRowDeserializationSchema | From | To | |
| Rename Variable | 2 | ||
| Rename Variable descriptors : List<RowtimeAttributeDescriptor> to proctimeAttribute : Optional<String> in method public create(properties Map<String,String>) : TableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory | From | To | |
| Rename Variable props : Properties to kafkaProperties : Properties in method public create(properties Map<String,String>) : TableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory | From | To | |
| Pull Up Attribute | 4 | ||
| Pull Up Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka09TableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Pull Up Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka011TableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Pull Up Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka08TableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Pull Up Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka010TableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Rename Class | 3 | ||
| Rename Class org.apache.flink.formats.json.JsonSchemaConverter renamed to org.apache.flink.formats.json.JsonRowSchemaConverter | From | To | |
| Rename Class org.apache.flink.formats.json.JsonSchemaConverterTest renamed to org.apache.flink.formats.json.JsonRowSchemaConverterTest | From | To | |
| Rename Class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase renamed to org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type descriptors : List<RowtimeAttributeDescriptor> to proctimeAttribute : Optional<String> in method public create(properties Map<String,String>) : TableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory | From | To | |
| Extract Method | 2 | ||
| Extract Method private validateRowtimeAttributeDescriptors(rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>) : List<RowtimeAttributeDescriptor> extracted from protected setRowtimeAttributeDescriptors(rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Extract Method private validateProctimeAttribute(proctimeAttribute Optional<String>) : Optional<String> extracted from protected setProctimeAttribute(proctimeAttribute String) : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type proctimeAttribute : String to proctimeAttribute : Optional<String> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To |