|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected createKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected abstract createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected abstract getExpectedKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected createKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected createKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected abstract createKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected getExpectedKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected abstract build() : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.Builder |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected createKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactory |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected getExpectedKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected abstract getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected getExpectedKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected abstract getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |
|
Change Return Type KafkaTableSource to KafkaTableSourceBase in method protected getExpectedKafkaTableSource(schema TableSchema, proctimeAttribute Optional<String>, rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>, fieldMapping Map<String,String>, topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, startupMode StartupMode, specificStartupOffsets Map<KafkaTopicPartition,Long>) : KafkaTableSourceBase in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSourceTest |
From |
To |
|
Change Return Type KafkaTableSink to KafkaTableSinkBase in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSinkBase in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactoryTest |
From |
To |
|
Change Return Type KafkaTableSource.Builder to KafkaTableSourceBase.Builder in method protected getBuilder() : KafkaTableSourceBase.Builder in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSourceTest |
From |
To |
|
Change Variable Type actualKafkaSink : KafkaTableSink to actualKafkaSink : KafkaTableSinkBase in method public testTableSink() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testProctimeAttribute() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type source : KafkaTableSource to source : KafkaTableSourceBase in method public testRowtimeAttribute2() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type source : KafkaTableSource to source : KafkaTableSourceBase in method public testConsumerOffsets() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type source : KafkaTableSource to source : KafkaTableSourceBase in method public testRowtimeAttribute() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testTableSchema() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type source : KafkaTableSource to source : KafkaTableSourceBase in method public testNoTimeAttributes() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type source : KafkaTableSource to source : KafkaTableSourceBase in method public testProctimeAttribute() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testRowtimeAttribute2() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testConsumerOffsets() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testKafkaConsumer() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testRowtimeAttribute() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type that : KafkaTableSource to that : KafkaTableSourceBase in method public equals(o Object) : boolean in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase |
From |
To |
|
Change Variable Type observed : KafkaTableSource to observed : KafkaTableSourceBase in method public testKafkaConsumer() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type source : KafkaTableSource to source : KafkaTableSourceBase in method public testTableSchema() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type expected : KafkaTableSink to expected : KafkaTableSinkBase in method public testTableSink() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |
|
Change Variable Type b : KafkaTableSource.Builder to b : KafkaTableSourceBase.Builder in method public testNoTimeAttributes() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBuilderTestBase |
From |
To |
|
Change Variable Type actualKafkaSource : KafkaTableSource to actualKafkaSource : KafkaTableSourceBase in method public testTableSource() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |
|
Change Variable Type builderSource : KafkaTableSource to builderSource : KafkaTableSourceBase in method private testTableSource(format FormatDescriptor) : void in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSourceFactoryTestBase |
From |
To |
|
Change Variable Type expected : KafkaTableSource to expected : KafkaTableSourceBase in method public testTableSource() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |