Package org.apache.flink.table.connector.source.abilities

Interface Summary

Interface	Description
SupportsAggregatePushDown	Enables to push down the local aggregates into a ScanTableSource.
SupportsDynamicFiltering	Pushes dynamic filter into ScanTableSource, the table source can filter the partitions even the input data in runtime to reduce scan I/O.
SupportsFilterPushDown	Enables to push down filters into a ScanTableSource.
SupportsLimitPushDown	Enables to push down a limit (the expected maximum number of produced records) into a ScanTableSource.
SupportsPartitionPushDown	Enables to pass available partitions to the planner and push down partitions into a ScanTableSource.
SupportsProjectionPushDown	Enables to push down a (possibly nested) projection into a ScanTableSource.
SupportsReadingMetadata	Interface for ScanTableSources that support reading metadata columns.
SupportsSourceWatermark	Enables to fully rely on the watermark strategy provided by the ScanTableSource itself.
SupportsStatisticReport	Enables to report the estimated statistics provided by the DynamicTableSource.
SupportsWatermarkPushDown	Enables to push down a watermark strategy into a ScanTableSource.

Class Summary

Class	Description
SupportsFilterPushDown.Result	Result of a filter push down.