|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactoryTest |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactory |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method public Kafka09TableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSink |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected abstract getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryTestBase |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactoryTest |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactoryTest |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSourceSinkFactory |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected abstract createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected getExpectedKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactoryTest |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSourceSinkFactory |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method public Kafka010TableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSink |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected KafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) in class org.apache.flink.streaming.connectors.kafka.KafkaTableSink |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method protected createKafkaTableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) : KafkaTableSink in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSourceSinkFactory |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method public Kafka011TableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka011TableSink |
From |
To |
|
Change Parameter Type partitioner : FlinkKafkaPartitioner<Row> to partitioner : Optional<FlinkKafkaPartitioner<Row>> in method public Kafka08TableSink(schema TableSchema, topic String, properties Properties, partitioner Optional<FlinkKafkaPartitioner<Row>>, serializationSchema SerializationSchema<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSink |
From |
To |