Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Field and Description |
---|---|
protected DecodingFormat<DeserializationSchema<RowData>> |
KafkaDynamicSourceBase.decodingFormat
Scan format for decoding records from Kafka.
|
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.
|
Constructor and Description |
---|
Kafka010DynamicSource(DataType outputDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Creates a Kafka 0.10
StreamTableSource . |
Kafka011DynamicSource(DataType outputDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Creates a Kafka 0.11
ScanTableSource . |
KafkaDynamicSource(DataType outputDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Creates a generic Kafka
StreamTableSource . |
KafkaDynamicSourceBase(DataType outputDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Creates a generic Kafka
StreamTableSource . |
Modifier and Type | Class and Description |
---|---|
class |
ChangelogCsvFormat
The
ChangelogCsvFormat is a decoding format that uses a DeserializationSchema
during runtime. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Constructor and Description |
---|
SocketDynamicTableSource(String hostname,
int port,
byte byteDelimiter,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
DataType producedDataType) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
<I,F extends DecodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverDecodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
DecodingFormat of the given type using the given option as factory
identifier. |
Modifier and Type | Method and Description |
---|---|
<I,F extends DecodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverOptionalDecodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
DecodingFormat of the given type using the given option (if present)
as factory identifier. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.