Modifier and Type | Method and Description |
---|---|
static Optional<LogStoreTableFactory> |
AbstractFlinkTableFactory.createOptionalLogStoreFactory(org.apache.flink.table.factories.DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
static class |
FlinkFactoryUtil.FlinkFactoryHelper<F extends LogStoreTableFactory>
Base flink helper utility for validating all options for a
LogStoreTableFactory . |
Modifier and Type | Field and Description |
---|---|
protected F |
FlinkFactoryUtil.FlinkFactoryHelper.factory |
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 . |
Modifier and Type | Class and Description |
---|---|
class |
KafkaLogStoreFactory
The Kafka
LogStoreTableFactory implementation. |
Modifier and Type | Method and Description |
---|---|
static LogStoreTableFactory |
LogStoreTableFactory.discoverLogStoreFactory(ClassLoader cl,
String identifier) |
Modifier and Type | Field and Description |
---|---|
protected LogStoreTableFactory |
FlinkTableSinkBase.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) |
Modifier and Type | Field and Description |
---|---|
protected LogStoreTableFactory |
BaseDataTableSource.logStoreTableFactory |
Constructor and Description |
---|
BaseDataTableSource(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,
boolean isBatchCountStar) |
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,
boolean isBatchCountStar) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.