org.apache.flink.streaming.connectors.kafka

Class KafkaJsonTableSink

java.lang.Object

org.apache.flink.streaming.connectors.kafka.KafkaTableSink

org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSink

All Implemented Interfaces:

org.apache.flink.table.sinks.AppendStreamTableSink<Row>, org.apache.flink.table.sinks.TableSink<Row>

Direct Known Subclasses:

Kafka010JsonTableSink, Kafka08JsonTableSink, Kafka09JsonTableSink

public abstract class KafkaJsonTableSink
extends KafkaTableSink

Base class for KafkaTableSink that serializes data in JSON format.

Field Summary

Fields inherited from class org.apache.flink.streaming.connectors.kafka.KafkaTableSink

fieldNames, fieldTypes, partitioner, properties, serializationSchema, topic

Constructor Summary

Constructors

Constructor and Description
KafkaJsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner) Creates KafkaJsonTableSink.

Method Summary

Modifier and Type	Method and Description
protected SerializationSchema<Row>	createSerializationSchema(RowTypeInfo rowSchema) Create serialization schema for converting table rows into bytes.

Methods inherited from class org.apache.flink.streaming.connectors.kafka.KafkaTableSink

configure, createCopy, createKafkaProducer, emitDataStream, getFieldNames, getFieldTypes, getOutputType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaJsonTableSink

public KafkaJsonTableSink(String topic,
                          Properties properties,
                          FlinkKafkaPartitioner<Row> partitioner)

Creates KafkaJsonTableSink.

Parameters:

topic - topic in Kafka to which table is written

properties - properties to connect to Kafka

partitioner - Kafka partitioner

Method Detail

createSerializationSchema

protected SerializationSchema<Row> createSerializationSchema(RowTypeInfo rowSchema)

Description copied from class: KafkaTableSink

Create serialization schema for converting table rows into bytes.

Specified by:

createSerializationSchema in class KafkaTableSink

Parameters:

rowSchema - the schema of the row to serialize.

Returns:

Instance of serialization schema