public class Kafka08JsonTableSink extends KafkaJsonTableSink
KafkaTableSink
that serializes data in JSON format.fieldNames, fieldTypes, partitioner, properties, serializationSchema, topic
Constructor and Description |
---|
Kafka08JsonTableSink(String topic,
Properties properties,
KafkaPartitioner<Row> partitioner)
Creates
KafkaTableSink for Kafka 0.8 |
Modifier and Type | Method and Description |
---|---|
protected Kafka08JsonTableSink |
createCopy()
Create a deep copy of this sink.
|
protected FlinkKafkaProducerBase<Row> |
createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
KafkaPartitioner<Row> partitioner)
Returns the version-specifid Kafka producer.
|
createSerializationSchema
configure, emitDataStream, getFieldNames, getFieldTypes, getOutputType
public Kafka08JsonTableSink(String topic, Properties properties, KafkaPartitioner<Row> partitioner)
KafkaTableSink
for Kafka 0.8topic
- topic in Kafka to which table is writtenproperties
- properties to connect to Kafkapartitioner
- Kafka partitionerprotected FlinkKafkaProducerBase<Row> createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, KafkaPartitioner<Row> partitioner)
KafkaTableSink
createKafkaProducer
in class KafkaTableSink
topic
- Kafka topic to produce to.properties
- Properties for the Kafka producer.serializationSchema
- Serialization schema to use to create Kafka records.partitioner
- Partitioner to select Kafka partition.protected Kafka08JsonTableSink createCopy()
KafkaTableSink
createCopy
in class KafkaTableSink
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.