0e92b6632f35b69c62d7747f1cbaa3ee207fb235
Files Diff
- Added: 9
- Removed: 2
- Renamed: 0
- Modified: 34
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 4 | ||
| Change Parameter Type typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka010JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource | From | To | |
| Change Parameter Type typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka09JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource | From | To | |
| Change Parameter Type typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka011JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource | From | To | |
| Change Parameter Type typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka08JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource | From | To | |
| Move Method | 1 | ||
| Move Method protected getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka010TableSource | From | To | |
| Push Down Attribute | 2 | ||
| Push Down Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka09TableSource | From | To | |
| Push Down Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka08TableSource | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka011TableSource | From | To | |
| Move Attribute private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to private deserializationSchema : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka010TableSource | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase.AvroSpecificRecord moved and renamed to org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSourceTestBase.DifferentFieldsAvroClass | From | To | |
| Rename Method | 3 | ||
| Rename Method private createDeserializationSchema(record Class<? extends SpecificRecordBase>) : AvroRowDeserializationSchema renamed to protected getDeserializationSchema() : AvroRowDeserializationSchema in class org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource | From | To | |
| Rename Method public testKafkaTableSource() : void renamed to public testKafkaConsumer() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase | From | To | |
| Rename Method public explainSource() : String renamed to public getProctimeAttribute() : String in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Push Down Method | 2 | ||
| Push Down Method protected getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka09TableSource | From | To | |
| Push Down Method protected getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSource to public getDeserializationSchema() : DeserializationSchema<Row> from class org.apache.flink.streaming.connectors.kafka.Kafka08TableSource | From | To | |
| Rename Variable | 1 | ||
| Rename Variable kafkaTableSource : KafkaTableSource to observed : KafkaTableSource in method public testKafkaConsumer() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute record : Class<? extends SpecificRecordBase> to avroRecordClass : Class<? extends SpecificRecordBase> in method protected getDeserializationSchema() : AvroRowDeserializationSchema in class org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource | From | To | |
| Extract Superclass | 2 | ||
| Extract Superclass org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSourceTestBase from classes [org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSourceTest, org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSourceTest, org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSourceTest, org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSourceTest] | From | To | |
| Extract Superclass org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceTestBase from classes [org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSourceTest, org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSourceTest, org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSourceTest, org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSourceTest] | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute PROPERTIES : Properties to PROPS : Properties in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase | From | To | |
| Rename Attribute typeInfo : TypeInformation<Row> to returnType : TypeInformation<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type FIELD_TYPES : TypeInformation<?>[] to FIELD_TYPES : TypeInformation[] in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase | From | To | |
| Rename Parameter | 5 | ||
| Rename Parameter typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka011JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource | From | To | |
| Rename Parameter typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka08JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource | From | To | |
| Rename Parameter typeInfo : TypeInformation<Row> to returnType : TypeInformation<Row> in method protected KafkaTableSource(topic String, properties Properties, schema TableSchema, returnType TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource | From | To | |
| Rename Parameter typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka010JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource | From | To | |
| Rename Parameter typeInfo : TypeInformation<Row> to tableSchema : TableSchema in method public Kafka09JsonTableSource(topic String, properties Properties, tableSchema TableSchema, jsonSchema TableSchema) in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource | From | To |