@Deprecated @Internal public abstract class KafkaJsonTableSink extends KafkaTableSinkBase
KafkaTableSinkBase
that serializes data in JSON format.fieldNames, fieldTypes, partitioner, properties, serializationSchema, topic
Constructor and Description |
---|
KafkaJsonTableSink(String topic,
Properties properties,
FlinkKafkaPartitioner<Row> partitioner)
Deprecated.
Use table descriptors instead of implementation-specific classes.
|
Modifier and Type | Method and Description |
---|---|
protected SerializationSchema<Row> |
createSerializationSchema(RowTypeInfo rowSchema)
Deprecated.
Create serialization schema for converting table rows into bytes.
|
configure, createCopy, createKafkaProducer, emitDataStream, equals, getFieldNames, getFieldTypes, getOutputType, hashCode
@Deprecated public KafkaJsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner)
topic
- topic in Kafka to which table is writtenproperties
- properties to connect to Kafkapartitioner
- Kafka partitionerprotected SerializationSchema<Row> createSerializationSchema(RowTypeInfo rowSchema)
KafkaTableSinkBase
createSerializationSchema
in class KafkaTableSinkBase
rowSchema
- the schema of the row to serialize.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.