org.apache.flink.table.planner.plan.abilities.source

Interface SourceAbilitySpec

All Known Implementing Classes:

AggregatePushDownSpec, FilterPushDownSpec, LimitPushDownSpec, PartitionPushDownSpec, ProjectPushDownSpec, ReadingMetadataSpec, SourceAbilitySpecBase, SourceWatermarkSpec, WatermarkPushDownSpec

@Internal
public interface SourceAbilitySpec

An interface that can not only serialize/deserialize the source abilities to/from JSON, but also can apply the abilities to a DynamicTableSource.

Method Summary

Modifier and Type	Method and Description
void	apply(DynamicTableSource tableSource, SourceAbilityContext context) Apply the ability to the given DynamicTableSource.
String	getDigests(SourceAbilityContext context) Additional digests to generate when this spec is applied to the source.
Optional<RowType>	getProducedType() Return the produced RowType this the ability is applied.

Method Detail

apply

void apply(DynamicTableSource tableSource,
           SourceAbilityContext context)

Apply the ability to the given DynamicTableSource.

getProducedType

Optional<RowType> getProducedType()

Return the produced RowType this the ability is applied.

NOTE: If the ability does not change the produced type, this method will return Optional.empty().

getDigests

String getDigests(SourceAbilityContext context)

Additional digests to generate when this spec is applied to the source.

Parameters:

context - The context about the source.