Kafka
descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor)
.@Deprecated public class Kafka09JsonTableSink extends KafkaJsonTableSink
KafkaTableSinkBase
that serializes data in JSON format.fieldNames, fieldTypes, partitioner, properties, serializationSchema, topic
Constructor and Description |
---|
Kafka09JsonTableSink(String topic,
Properties properties)
Deprecated.
Use table descriptors instead of implementation-specific classes.
|
Kafka09JsonTableSink(String topic,
Properties properties,
FlinkKafkaPartitioner<Row> partitioner)
Deprecated.
Use table descriptors instead of implementation-specific classes.
|
Kafka09JsonTableSink(String topic,
Properties properties,
KafkaPartitioner<Row> partitioner)
Deprecated.
This is a deprecated constructor that does not correctly handle partitioning when
producing to multiple topics. Use
Kafka09JsonTableSink(String, Properties, FlinkKafkaPartitioner) instead. |
Modifier and Type | Method and Description |
---|---|
protected Kafka09JsonTableSink |
createCopy()
Deprecated.
Create a deep copy of this sink.
|
protected FlinkKafkaProducerBase<Row> |
createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner)
Deprecated.
Returns the version-specific Kafka producer.
|
createSerializationSchema
configure, emitDataStream, equals, getFieldNames, getFieldTypes, getOutputType, hashCode
@Deprecated public Kafka09JsonTableSink(String topic, Properties properties)
KafkaTableSinkBase
to write table rows as JSON-encoded records to a Kafka 0.9
topic with fixed partition assignment.
Each parallel TableSink instance will write its rows to a single Kafka partition.
topic
- topic in Kafka to which table is writtenproperties
- properties to connect to Kafka@Deprecated public Kafka09JsonTableSink(String topic, Properties properties, FlinkKafkaPartitioner<Row> partitioner)
KafkaTableSinkBase
to write table rows as JSON-encoded records to a Kafka 0.9
topic with custom partition assignment.topic
- topic in Kafka to which table is writtenproperties
- properties to connect to Kafkapartitioner
- Kafka partitioner@Deprecated public Kafka09JsonTableSink(String topic, Properties properties, KafkaPartitioner<Row> partitioner)
Kafka09JsonTableSink(String, Properties, FlinkKafkaPartitioner)
instead.KafkaTableSinkBase
to write table rows as JSON-encoded records to a Kafka 0.9
topic with custom partition assignment.topic
- 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, Optional<FlinkKafkaPartitioner<Row>> partitioner)
KafkaTableSinkBase
createKafkaProducer
in class KafkaTableSinkBase
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 Kafka09JsonTableSink createCopy()
KafkaTableSinkBase
createCopy
in class KafkaTableSinkBase
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.