|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method private createTableSink() : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBaseTestBase |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSinkTest |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected abstract createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBaseTestBase |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createCopy() : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method public configure(fieldNames String[], fieldTypes TypeInformation<?>[]) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSinkTest |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createTableSink(topic String, properties Properties, partitioner FlinkKafkaPartitioner<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSinkTest |
From |
To |
|
Change Variable Type newKafkaTableSink : KafkaTableSink to newKafkaTableSink : KafkaTableSinkBase in method public testConfiguration() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBaseTestBase |
From |
To |
|
Change Variable Type sink : KafkaTableSink to sink : KafkaTableSinkBase in method private createTableSink() : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBaseTestBase |
From |
To |
|
Change Variable Type kafkaTableSink : KafkaTableSink to kafkaTableSink : KafkaTableSinkBase in method public testKafkaTableSink() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBaseTestBase |
From |
To |
|
Change Variable Type that : KafkaTableSink to that : KafkaTableSinkBase in method public equals(o Object) : boolean in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase |
From |
To |
|
Change Variable Type kafkaTableSink : KafkaTableSink to kafkaTableSink : KafkaTableSinkBase in method public testConfiguration() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBaseTestBase |
From |
To |
|
Change Variable Type copy : KafkaTableSink to copy : KafkaTableSinkBase in method public configure(fieldNames String[], fieldTypes TypeInformation<?>[]) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase |
From |
To |