Class | Description |
---|---|
FlinkKafkaConsumer010<T> |
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.10.x.
|
FlinkKafkaConsumer08<T> |
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.8.x.
|
FlinkKafkaConsumer081<T> | Deprecated |
FlinkKafkaConsumer082<T> | Deprecated |
FlinkKafkaConsumer09<T> |
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.9.x.
|
FlinkKafkaConsumerBase<T> |
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaProducer<IN> | Deprecated
Use
FlinkKafkaProducer08 . |
FlinkKafkaProducer010<T> |
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T> |
Configuration object returned by the writeToKafkaWithTimestamps() call.
|
FlinkKafkaProducer08<IN> |
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducer09<IN> |
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducerBase<IN> |
Flink Sink to produce data into a Kafka topic.
|
Kafka010AvroTableSource |
Kafka
StreamTableSource for Kafka 0.10. |
Kafka010JsonTableSource |
Kafka
StreamTableSource for Kafka 0.10. |
Kafka010TableSource |
Kafka
StreamTableSource for Kafka 0.10. |
Kafka08AvroTableSource |
Kafka
StreamTableSource for Kafka 0.8. |
Kafka08JsonTableSink |
Kafka 0.8
KafkaTableSink that serializes data in JSON format. |
Kafka08JsonTableSource |
Kafka
StreamTableSource for Kafka 0.8. |
Kafka08TableSource |
Kafka
StreamTableSource for Kafka 0.8. |
Kafka09AvroTableSource |
Kafka
StreamTableSource for Kafka 0.9. |
Kafka09JsonTableSink |
Kafka 0.9
KafkaTableSink that serializes data in JSON format. |
Kafka09JsonTableSource |
Kafka
StreamTableSource for Kafka 0.9. |
Kafka09TableSource |
Kafka
StreamTableSource for Kafka 0.9. |
KafkaAvroTableSource |
A version-agnostic Kafka Avro
StreamTableSource . |
KafkaJsonTableSink |
Base class for
KafkaTableSink that serializes data in JSON format |
KafkaJsonTableSource |
A version-agnostic Kafka JSON
StreamTableSource . |
KafkaTableSink |
A version-agnostic Kafka
AppendStreamTableSink . |
KafkaTableSource |
A version-agnostic Kafka
StreamTableSource . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.