org.apache.paimon.flink.source.table

Class RichTableSource

java.lang.Object

org.apache.paimon.flink.source.table.BaseTableSource

org.apache.paimon.flink.source.table.RichTableSource

All Implemented Interfaces:

org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering, org.apache.flink.table.connector.source.abilities.SupportsStatisticReport, org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown, org.apache.flink.table.connector.source.DynamicTableSource, org.apache.flink.table.connector.source.LookupTableSource, org.apache.flink.table.connector.source.ScanTableSource

Direct Known Subclasses:

PushedRichTableSource

public class RichTableSource
extends BaseTableSource
implements org.apache.flink.table.connector.source.LookupTableSource, org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown, org.apache.flink.table.connector.source.abilities.SupportsStatisticReport, org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering

The BaseTableSource with lookup, watermark, statistic and dynamic filtering.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.LookupTableSource

org.apache.flink.table.connector.source.LookupTableSource.LookupContext, org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.ScanTableSource

org.apache.flink.table.connector.source.ScanTableSource.ScanContext, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

Constructor Summary

Constructors

Constructor and Description
RichTableSource(FlinkTableSource source)

Method Summary

Modifier and Type	Method and Description
void	applyDynamicFiltering(List<String> candidateFilterFields)
void	applyWatermark(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy)
RichTableSource	copy()
org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider	getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)
List<String>	listAcceptedFilterFields()
org.apache.flink.table.plan.stats.TableStats	reportStatistics()

Methods inherited from class org.apache.paimon.flink.source.table.BaseTableSource

asSummaryString, getChangelogMode, getScanRuntimeProvider

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

asSummaryString

Constructor Detail

RichTableSource

public RichTableSource(FlinkTableSource source)

Method Detail

copy

public RichTableSource copy()

Specified by:

copy in interface org.apache.flink.table.connector.source.DynamicTableSource

getLookupRuntimeProvider

public org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)

Specified by:

getLookupRuntimeProvider in interface org.apache.flink.table.connector.source.LookupTableSource

applyWatermark

public void applyWatermark(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy)

Specified by:

applyWatermark in interface org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown

reportStatistics

public org.apache.flink.table.plan.stats.TableStats reportStatistics()

Specified by:

reportStatistics in interface org.apache.flink.table.connector.source.abilities.SupportsStatisticReport

listAcceptedFilterFields

public List<String> listAcceptedFilterFields()

Specified by:

listAcceptedFilterFields in interface org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering

applyDynamicFiltering

public void applyDynamicFiltering(List<String> candidateFilterFields)

Specified by:

applyDynamicFiltering in interface org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering