Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010JsonTableSink
Kafka 0.10
KafkaTableSink that serializes data in JSON format. |
class |
Kafka08JsonTableSink
Kafka 0.8
KafkaTableSink that serializes data in JSON format. |
class |
Kafka09JsonTableSink
Kafka 0.9
KafkaTableSink that serializes data in JSON format. |
class |
KafkaJsonTableSink
Base class for
KafkaTableSink that serializes data in JSON format. |
Modifier and Type | Method and Description |
---|---|
KafkaTableSink |
KafkaTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
protected abstract KafkaTableSink |
KafkaTableSink.createCopy()
Create a deep copy of this sink.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.