public abstract class KafkaDynamicTableFactoryBase extends Object implements DynamicTableSourceFactory, DynamicTableSinkFactory
KafkaDynamicSourceBase
and KafkaDynamicSinkBase
.DynamicTableFactory.Context
Constructor and Description |
---|
KafkaDynamicTableFactoryBase() |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
createDynamicTableSink(DynamicTableFactory.Context context)
Creates a
DynamicTableSink instance from a CatalogTable and additional
context information. |
DynamicTableSource |
createDynamicTableSource(DynamicTableFactory.Context context)
Creates a
DynamicTableSource instance from a CatalogTable and additional
context information. |
protected abstract KafkaDynamicSinkBase |
createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat)
Constructs the version-specific Kafka table sink.
|
protected abstract KafkaDynamicSourceBase |
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.
|
Set<ConfigOption<?>> |
optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions() . |
Set<ConfigOption<?>> |
requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions() . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
factoryIdentifier
public DynamicTableSource createDynamicTableSource(DynamicTableFactory.Context context)
DynamicTableSourceFactory
DynamicTableSource
instance from a CatalogTable
and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSource
in interface DynamicTableSourceFactory
public DynamicTableSink createDynamicTableSink(DynamicTableFactory.Context context)
DynamicTableSinkFactory
DynamicTableSink
instance from a CatalogTable
and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSink
in interface DynamicTableSinkFactory
protected abstract KafkaDynamicSourceBase createKafkaTableSource(DataType producedDataType, String topic, Properties properties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
producedDataType
- Source produced data typetopic
- Kafka topic to consumeproperties
- Properties for the Kafka consumerdecodingFormat
- Decoding format for decoding records from KafkastartupMode
- Startup mode for the contained consumerspecificStartupOffsets
- Specific startup offsets; only relevant when startup mode is
StartupMode.SPECIFIC_OFFSETS
protected abstract KafkaDynamicSinkBase createKafkaTableSink(DataType consumedDataType, String topic, Properties properties, Optional<FlinkKafkaPartitioner<RowData>> partitioner, EncodingFormat<SerializationSchema<RowData>> encodingFormat)
consumedDataType
- Sink consumed data typetopic
- Kafka topic to consumeproperties
- Properties for the Kafka consumerpartitioner
- Partitioner to select Kafka partition for each itemencodingFormat
- Encoding format for encoding records to Kafkapublic Set<ConfigOption<?>> requiredOptions()
Factory
ConfigOption
that an implementation of this factory requires in
addition to Factory.optionalOptions()
.
See the documentation of Factory
for more information.
requiredOptions
in interface Factory
public Set<ConfigOption<?>> optionalOptions()
Factory
ConfigOption
that an implementation of this factory consumes in
addition to Factory.requiredOptions()
.
See the documentation of Factory
for more information.
optionalOptions
in interface Factory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.