|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSource |
From |
To |
|
Rename Method package getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSource |
From |
To |
|
Rename Method package abstract getKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> renamed to protected abstract createKafkaConsumer(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>) : FlinkKafkaConsumerBase<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSource |
From |
To |