public class DataTableSource extends BaseDataTableSource implements org.apache.flink.table.connector.source.abilities.SupportsStatisticReport, org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering
FlinkTableSource.SplitStatistics
org.apache.flink.table.connector.source.LookupTableSource.LookupContext, org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider
org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter
context, isBatchCountStar, logStoreTableFactory, streaming, tableIdentifier, watermarkStrategy
FLINK_INFER_SCAN_PARALLELISM, limit, predicate, projectFields, splitStatistics, table
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,
boolean isBatchCountStar) |
Modifier and Type | Method and Description |
---|---|
void |
applyDynamicFiltering(List<String> candidateFilterFields) |
DataTableSource |
copy() |
protected List<String> |
dynamicPartitionFilteringFields() |
List<String> |
listAcceptedFilterFields() |
org.apache.flink.table.plan.stats.TableStats |
reportStatistics() |
applyAggregates, applyWatermark, asSummaryString, getChangelogMode, getFileStoreLookupFunction, getLookupRuntimeProvider, getScanRuntimeProvider, isStreaming
applyFilters, applyLimit, applyProjection, getTable, inferSourceParallelism, scanSplitsForInference, supportsNestedProjection
public DataTableSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, boolean streaming, org.apache.flink.table.factories.DynamicTableFactory.Context context, @Nullable LogStoreTableFactory logStoreTableFactory)
public DataTableSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, boolean streaming, org.apache.flink.table.factories.DynamicTableFactory.Context context, @Nullable LogStoreTableFactory logStoreTableFactory, @Nullable Predicate predicate, @Nullable int[][] projectFields, @Nullable Long limit, @Nullable org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy, @Nullable List<String> dynamicPartitionFilteringFields, boolean isBatchCountStar)
public DataTableSource copy()
copy
in interface org.apache.flink.table.connector.source.DynamicTableSource
public org.apache.flink.table.plan.stats.TableStats reportStatistics()
reportStatistics
in interface org.apache.flink.table.connector.source.abilities.SupportsStatisticReport
public List<String> listAcceptedFilterFields()
listAcceptedFilterFields
in interface org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering
public void applyDynamicFiltering(List<String> candidateFilterFields)
applyDynamicFiltering
in interface org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering
protected List<String> dynamicPartitionFilteringFields()
dynamicPartitionFilteringFields
in class BaseDataTableSource
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.