flink 614b1e29eefd37fa22e7c882bc243751c6897b90

614b1e29eefd37fa22e7c882bc243751c6897b90

Files Diff

Added: 16
Removed: 1
Renamed: 0
Modified: 16

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Method	5
	Rename Method protected createBuilder() : KafkaJsonTableSource.Builder renamed to protected createKafkaJsonBuilder() : KafkaJsonTableSource.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSourceFactory	From	To
	Rename Method protected abstract createBuilder() : KafkaJsonTableSource.Builder renamed to protected abstract createKafkaJsonBuilder() : KafkaJsonTableSource.Builder in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory	From	To
	Rename Method protected createBuilder() : KafkaJsonTableSource.Builder renamed to protected createKafkaJsonBuilder() : KafkaJsonTableSource.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSourceFactory	From	To
	Rename Method protected createBuilder() : KafkaJsonTableSource.Builder renamed to protected createKafkaJsonBuilder() : KafkaJsonTableSource.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSourceFactory	From	To
	Rename Method protected createBuilder() : KafkaJsonTableSource.Builder renamed to protected createKafkaJsonBuilder() : KafkaJsonTableSource.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSourceFactory	From	To
	Pull Up Method	4
	Pull Up Method public supportedProperties() : List<String> from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory to public supportedProperties() : List<String> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory	From	To
	Pull Up Method public requiredContext() : Map<String,String> from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory to public requiredContext() : Map<String,String> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory	From	To
	Pull Up Method public create(properties Map<String,String>) : TableSource<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory to public create(properties Map<String,String>) : TableSource<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory	From	To
	Pull Up Method protected abstract kafkaVersion() : String from class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory to protected abstract kafkaVersion() : String from class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory	From	To
	Move And Rename Method	2
	Move And Rename Method private convertToTypeInformation(extracted TypeInformation<?>, schema Schema) : TypeInformation<?> from class org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource to private convertType(extracted TypeInformation<?>, schema Schema) : TypeInformation<?> from class org.apache.flink.formats.avro.typeutils.AvroRecordClassConverter	From	To
	Move And Rename Method private convertToRowTypeInformation(avroClass Class<T>) : TypeInformation<Row> from class org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource to public convert(avroClass Class<T>) : TypeInformation<Row> from class org.apache.flink.formats.avro.typeutils.AvroRecordClassConverter	From	To
	Extract Superclass	1
	Extract Superclass org.apache.flink.streaming.connectors.kafka.KafkaTableSourceFactory from classes [org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory]	From	To