org.apache.paimon.flink.log

Interface LogStoreTableFactory

All Superinterfaces:

Factory

All Known Implementing Classes:

KafkaLogStoreFactory

public interface LogStoreTableFactory
extends Factory

Base interface for configuring a default log table connector. The log table is used by managed table factory.

Log tables are for processing only unbounded data. Support streaming reading and streaming writing.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	LogStoreTableFactory.RegisterContext Context to create log store register.

Method Summary

Modifier and Type	Method and Description
LogStoreRegister	createRegister(LogStoreTableFactory.RegisterContext context) Creates a LogStoreRegister instance for table ddl, it will register table to log store when a table is created or dropped.
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)
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>>	getKeyDecodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>	getKeyEncodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>>	getValueDecodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>	getValueEncodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.configuration.ConfigOption<String>	logFormat()
static org.apache.flink.configuration.ConfigOption<String>	logKeyFormat()
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)

Methods inherited from interface org.apache.paimon.factories.Factory

identifier

Method Detail

createSourceProvider

LogSourceProvider createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                       org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext,
                                       @Nullable
                                       int[][] projectFields)

Creates a LogSourceProvider instance from a CatalogTable and additional context information.

createSinkProvider

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.

createRegister

LogStoreRegister createRegister(LogStoreTableFactory.RegisterContext context)

Creates a LogStoreRegister instance for table ddl, it will register table to log store when a table is created or dropped.

logKeyFormat

static org.apache.flink.configuration.ConfigOption<String> logKeyFormat()

logFormat

static org.apache.flink.configuration.ConfigOption<String> logFormat()

discoverLogStoreFactory

static LogStoreTableFactory discoverLogStoreFactory(ClassLoader cl,
                                                    String identifier)

getKeyDecodingFormat

static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>> getKeyDecodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)

getKeyEncodingFormat

static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> getKeyEncodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)

getValueDecodingFormat

static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>> getValueDecodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)

getValueEncodingFormat

static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> getValueEncodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)

validateKeyFormat

static void validateKeyFormat(org.apache.flink.table.connector.format.Format format,
                              String name)

validateValueFormat

static void validateValueFormat(org.apache.flink.table.connector.format.Format format,
                                String name)