public interface LogStoreTableFactory
extends org.apache.flink.table.factories.DynamicTableFactory
Log tables are for processing only unbounded data. Support streaming reading and streaming writing.
Modifier and Type | Method and Description |
---|---|
LogSinkProvider |
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. |
LogSourceProvider |
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. |
static LogStoreTableFactory |
discoverLogStoreFactory(ClassLoader cl,
String identifier) |
Map<String,String> |
enrichOptions(org.apache.flink.table.factories.DynamicTableFactory.Context context)
Enrich options from catalog and session information.
|
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>> |
getKeyDecodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper) |
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> |
getKeyEncodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper) |
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>> |
getValueDecodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper) |
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> |
getValueEncodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper) |
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.
|
static void |
validateKeyFormat(org.apache.flink.table.connector.format.Format format,
String name) |
static void |
validateValueFormat(org.apache.flink.table.connector.format.Format format,
String name) |
Map<String,String> enrichOptions(org.apache.flink.table.factories.DynamicTableFactory.Context context)
void onCreateTable(org.apache.flink.table.factories.DynamicTableFactory.Context context, int numBucket, boolean ignoreIfExists)
void onDropTable(org.apache.flink.table.factories.DynamicTableFactory.Context context, boolean ignoreIfNotExists)
LogSourceProvider createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext, @Nullable int[][] projectFields)
LogSourceProvider
instance from a CatalogTable
and additional
context information.LogSinkProvider createSinkProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.sink.DynamicTableSink.Context sinkContext)
LogSinkProvider
instance from a CatalogTable
and additional context
information.static LogStoreTableFactory discoverLogStoreFactory(ClassLoader cl, String identifier)
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>> getKeyDecodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper)
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> getKeyEncodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper)
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>> getValueDecodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper)
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> getValueEncodingFormat(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper)
static void validateKeyFormat(org.apache.flink.table.connector.format.Format format, String name)
static void validateValueFormat(org.apache.flink.table.connector.format.Format format, String name)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.