Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka |
Modifier and Type | Class and Description |
---|---|
protected static class |
KafkaAvroTableSource.Builder<T extends KafkaAvroTableSource,B extends KafkaAvroTableSource.Builder>
Abstract builder for a
KafkaAvroTableSource to be extended by builders of subclasses of
KafkaAvroTableSource. |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010AvroTableSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka011AvroTableSource
Kafka
StreamTableSource for Kafka 0.11. |
class |
Kafka08AvroTableSource
Kafka
StreamTableSource for Kafka 0.8. |
class |
Kafka09AvroTableSource
Kafka
StreamTableSource for Kafka 0.9. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.