Uses of Interface
org.apache.paimon.flink.log.LogStoreTableFactory

Packages that use LogStoreTableFactory

Package	Description
org.apache.paimon.flink
org.apache.paimon.flink.factories
org.apache.paimon.flink.kafka
org.apache.paimon.flink.log
org.apache.paimon.flink.sink
org.apache.paimon.flink.source

Uses of LogStoreTableFactory in org.apache.paimon.flink

Methods in org.apache.paimon.flink that return types with arguments of type LogStoreTableFactory

Modifier and Type	Method and Description
static Optional<LogStoreTableFactory>	AbstractFlinkTableFactory.createOptionalLogStoreFactory(org.apache.flink.table.factories.DynamicTableFactory.Context context)

Uses of LogStoreTableFactory in org.apache.paimon.flink.factories

Classes in org.apache.paimon.flink.factories with type parameters of type LogStoreTableFactory

Modifier and Type	Class and Description
static class	FlinkFactoryUtil.FlinkFactoryHelper<F extends LogStoreTableFactory> Base flink helper utility for validating all options for a LogStoreTableFactory.

Fields in org.apache.paimon.flink.factories declared as LogStoreTableFactory

Modifier and Type	Field and Description
protected F	FlinkFactoryUtil.FlinkFactoryHelper.factory

Methods in org.apache.paimon.flink.factories with parameters of type LogStoreTableFactory

Modifier and Type	Method and Description
static FlinkFactoryUtil.FlinkTableFactoryHelper	FlinkFactoryUtil.createFlinkTableFactoryHelper(LogStoreTableFactory factory, org.apache.flink.table.factories.DynamicTableFactory.Context context) Creates a utility that helps in discovering formats, merging options with DynamicTableFactory.Context#getEnrichmentOptions() and validating them all for a LogStoreTableFactory.

Uses of LogStoreTableFactory in org.apache.paimon.flink.kafka

Classes in org.apache.paimon.flink.kafka that implement LogStoreTableFactory

Modifier and Type	Class and Description
class	KafkaLogStoreFactory The Kafka LogStoreTableFactory implementation.

Uses of LogStoreTableFactory in org.apache.paimon.flink.log

Methods in org.apache.paimon.flink.log that return LogStoreTableFactory

Modifier and Type	Method and Description
static LogStoreTableFactory	LogStoreTableFactory.discoverLogStoreFactory(ClassLoader cl, String identifier)

Uses of LogStoreTableFactory in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink declared as LogStoreTableFactory

Modifier and Type	Field and Description
protected LogStoreTableFactory	FlinkTableSinkBase.logStoreTableFactory

Constructors in org.apache.paimon.flink.sink with parameters of type LogStoreTableFactory

Constructor and Description
FlinkTableSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory)
FlinkTableSinkBase(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory)
SupportsRowLevelOperationFlinkTableSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory)

Uses of LogStoreTableFactory in org.apache.paimon.flink.source

Constructors in org.apache.paimon.flink.source with parameters of type LogStoreTableFactory

Constructor and Description
DataTableSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, boolean streaming, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory)
DataTableSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, boolean streaming, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory, Predicate predicate, int[][] projectFields, Long limit, org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy, List<String> dynamicPartitionFilteringFields)