Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka.table |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010DynamicSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka011DynamicSource
Kafka
StreamTableSource for Kafka 0.11. |
class |
KafkaDynamicSource
Kafka
DynamicTableSource . |
Modifier and Type | Method and Description |
---|---|
protected KafkaDynamicSourceBase |
KafkaDynamicTableFactory.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis) |
protected KafkaDynamicSourceBase |
Kafka011DynamicTableFactory.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis) |
protected KafkaDynamicSourceBase |
Kafka010DynamicTableFactory.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis) |
protected abstract KafkaDynamicSourceBase |
KafkaDynamicTableFactoryBase.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Constructs the version-specific Kafka table source.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.