public class KafkaLogStoreFactory extends Object implements LogStoreTableFactory
LogStoreTableFactory
implementation.Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
static String |
KAFKA_PREFIX |
Constructor and Description |
---|
KafkaLogStoreFactory() |
Modifier and Type | Method and Description |
---|---|
KafkaLogSinkProvider |
createSinkProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context,
org.apache.flink.table.connector.sink.DynamicTableSink.Context sinkContext)
Creates a
LogSinkProvider instance from a CatalogTable and additional context
information. |
KafkaLogSourceProvider |
createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context,
org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext,
int[][] projectFields)
Creates a
LogSourceProvider instance from a CatalogTable and additional
context information. |
Map<String,String> |
enrichOptions(org.apache.flink.table.factories.DynamicTableFactory.Context context)
Enrich options from catalog and session information.
|
String |
factoryIdentifier() |
void |
onCreateTable(org.apache.flink.table.factories.DynamicTableFactory.Context context,
int numBucket,
boolean ignoreIfExists)
Notifies the listener that a table creation occurred.
|
void |
onDropTable(org.apache.flink.table.factories.DynamicTableFactory.Context context,
boolean ignoreIfNotExists)
Notifies the listener that a table drop occurred.
|
Set<org.apache.flink.configuration.ConfigOption<?>> |
optionalOptions() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
requiredOptions() |
static Properties |
toKafkaProperties(org.apache.flink.configuration.ReadableConfig options) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
discoverLogStoreFactory, getKeyDecodingFormat, getKeyEncodingFormat, getValueDecodingFormat, getValueEncodingFormat, validateKeyFormat, validateValueFormat
public static final String IDENTIFIER
public static final String KAFKA_PREFIX
public String factoryIdentifier()
factoryIdentifier
in interface org.apache.flink.table.factories.Factory
public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
requiredOptions
in interface org.apache.flink.table.factories.Factory
public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
optionalOptions
in interface org.apache.flink.table.factories.Factory
public Map<String,String> enrichOptions(org.apache.flink.table.factories.DynamicTableFactory.Context context)
LogStoreTableFactory
enrichOptions
in interface LogStoreTableFactory
public void onCreateTable(org.apache.flink.table.factories.DynamicTableFactory.Context context, int numBucket, boolean ignoreIfExists)
LogStoreTableFactory
onCreateTable
in interface LogStoreTableFactory
public void onDropTable(org.apache.flink.table.factories.DynamicTableFactory.Context context, boolean ignoreIfNotExists)
LogStoreTableFactory
onDropTable
in interface LogStoreTableFactory
public KafkaLogSourceProvider createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext, @Nullable int[][] projectFields)
LogStoreTableFactory
LogSourceProvider
instance from a CatalogTable
and additional
context information.createSourceProvider
in interface LogStoreTableFactory
public KafkaLogSinkProvider createSinkProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.sink.DynamicTableSink.Context sinkContext)
LogStoreTableFactory
LogSinkProvider
instance from a CatalogTable
and additional context
information.createSinkProvider
in interface LogStoreTableFactory
public static Properties toKafkaProperties(org.apache.flink.configuration.ReadableConfig options)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.