|
Rename Variable tableJsonMapping : Map<String,String> to mapping : Map<String,String> in method public create(properties Map<String,String>) : TableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory |
From |
To |
|
Rename Variable entry : Map.Entry<Integer,Long> to specificOffset : Map.Entry<Integer,Long> in method public addConnectorProperties(properties DescriptorProperties) : void in class org.apache.flink.table.descriptors.Kafka |
From |
To |
|
Rename Variable versionValidatorMap : Map<String,Function0<BoxedUnit>> to specificOffsetValidators : Map<String,Consumer<String>> in method public validate(properties DescriptorProperties) : void in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Variable otherSource : KafkaJsonTableSource to that : KafkaJsonTableSource in method public equals(o Object) : boolean in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource |
From |
To |
|
Rename Variable other : KafkaTableSource to that : KafkaTableSource in method public equals(o Object) : boolean in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource |
From |
To |
|
Rename Variable kafkaProps : Properties to props : Properties in method public create(properties Map<String,String>) : TableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory |
From |
To |
|
Rename Variable tableSchema : TableSchema to schema : TableSchema in method public create(properties Map<String,String>) : TableSource<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactory |
From |
To |
|
Rename Attribute CONNECTOR_TYPE_VALUE : String to CONNECTOR_TYPE_VALUE_KAFKA : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute GROUP_ID : String to CONNECTOR_TOPIC : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute BOOTSTRAP_SERVERS : String to CONNECTOR_PROPERTIES : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute STARTUP_MODE : String to CONNECTOR_STARTUP_MODE : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute STARTUP_MODE_VALUE_LATEST : String to CONNECTOR_STARTUP_MODE_VALUE_LATEST : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute TOPIC : String to CONNECTOR_TOPIC : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute STARTUP_MODE_VALUE_EARLIEST : String to CONNECTOR_STARTUP_MODE_VALUE_EARLIEST : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute STARTUP_MODE_VALUE_GROUP_OFFSETS : String to CONNECTOR_STARTUP_MODE_VALUE_GROUP_OFFSETS : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute SPECIFIC_OFFSETS : String to CONNECTOR_SPECIFIC_OFFSETS : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute PARTITION : String to CONNECTOR_SPECIFIC_OFFSETS_PARTITION : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |
|
Rename Attribute OFFSET : String to CONNECTOR_SPECIFIC_OFFSETS_OFFSET : String in class org.apache.flink.table.descriptors.KafkaValidator |
From |
To |