Uses of Class
org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase

Packages that use KafkaTableSinkBase

Package	Description
org.apache.flink.streaming.connectors.kafka

Uses of KafkaTableSinkBase in org.apache.flink.streaming.connectors.kafka

Subclasses of KafkaTableSinkBase in org.apache.flink.streaming.connectors.kafka

Modifier and Type	Class and Description
class	Kafka010TableSink Kafka 0.10 table sink for writing data into Kafka.
class	Kafka011TableSink Kafka 0.11 table sink for writing data into Kafka.
class	KafkaTableSink Kafka table sink for writing data into Kafka.

Methods in org.apache.flink.streaming.connectors.kafka that return KafkaTableSinkBase

Modifier and Type	Method and Description
KafkaTableSinkBase	KafkaTableSinkBase.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
protected KafkaTableSinkBase	KafkaTableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka011TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka010TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected abstract KafkaTableSinkBase	KafkaTableSourceSinkFactoryBase.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema) Constructs the version-specific Kafka table sink.