public class TableStoreSource extends FlinkTableSource implements org.apache.flink.table.connector.source.LookupTableSource, org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown
StaticFileStoreSource
or ContinuousFileStoreSource
under
batch mode or change-tracking is disabled. For streaming mode with change-tracking enabled and
FULL scan mode, it will create a HybridSource
of StaticFileStoreSource
and
kafka log source created by LogSourceProvider
.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
limit, predicate, projectFields
Constructor and Description |
---|
TableStoreSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
FileStoreTable table,
boolean streaming,
org.apache.flink.table.factories.DynamicTableFactory.Context context,
LogStoreTableFactory logStoreTableFactory) |
Modifier and Type | Method and Description |
---|---|
void |
applyWatermark(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy) |
String |
asSummaryString() |
org.apache.flink.table.connector.source.DynamicTableSource |
copy() |
org.apache.flink.table.connector.ChangelogMode |
getChangelogMode() |
org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider |
getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context) |
org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider |
getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext) |
applyFilters, applyLimit, applyProjection, supportsNestedProjection
public TableStoreSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, FileStoreTable table, boolean streaming, org.apache.flink.table.factories.DynamicTableFactory.Context context, @Nullable LogStoreTableFactory logStoreTableFactory)
public org.apache.flink.table.connector.ChangelogMode getChangelogMode()
getChangelogMode
in interface org.apache.flink.table.connector.source.ScanTableSource
public org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext)
getScanRuntimeProvider
in interface org.apache.flink.table.connector.source.ScanTableSource
public org.apache.flink.table.connector.source.DynamicTableSource copy()
copy
in interface org.apache.flink.table.connector.source.DynamicTableSource
public String asSummaryString()
asSummaryString
in interface org.apache.flink.table.connector.source.DynamicTableSource
public void applyWatermark(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy)
applyWatermark
in interface org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown
public org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)
getLookupRuntimeProvider
in interface org.apache.flink.table.connector.source.LookupTableSource
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.