Uses of Interface
org.apache.flink.table.planner.plan.abilities.source.SourceAbilitySpec

Packages that use SourceAbilitySpec

Package	Description
org.apache.flink.table.planner.connectors
org.apache.flink.table.planner.plan.abilities.source
org.apache.flink.table.planner.plan.nodes.exec.spec
org.apache.flink.table.planner.plan.reuse

Uses of SourceAbilitySpec in org.apache.flink.table.planner.connectors

Method parameters in org.apache.flink.table.planner.connectors with type arguments of type SourceAbilitySpec

Modifier and Type	Method and Description
static void	DynamicSourceUtils.prepareDynamicSource(String tableDebugName, org.apache.flink.table.catalog.ResolvedCatalogTable table, org.apache.flink.table.connector.source.DynamicTableSource source, boolean isBatchMode, org.apache.flink.configuration.ReadableConfig config, List<SourceAbilitySpec> sourceAbilities) Prepares the given DynamicTableSource.
static void	DynamicSourceUtils.validateAndApplyMetadata(String tableDebugName, org.apache.flink.table.catalog.ResolvedSchema schema, org.apache.flink.table.connector.source.DynamicTableSource source, List<SourceAbilitySpec> sourceAbilities)

Uses of SourceAbilitySpec in org.apache.flink.table.planner.plan.abilities.source

Classes in org.apache.flink.table.planner.plan.abilities.source that implement SourceAbilitySpec

Modifier and Type	Class and Description
class	AggregatePushDownSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the aggregation to/from JSON, but also can push the local aggregate into a SupportsAggregatePushDown.
class	FilterPushDownSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the filter to/from JSON, but also can push the filter into a SupportsFilterPushDown.
class	LimitPushDownSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the limit value to/from JSON, but also can push the limit value into a LimitPushDownSpec.
class	PartitionPushDownSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the partitions to/from JSON, but also can push the partitions into a SupportsPartitionPushDown.
class	ProjectPushDownSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the projection to/from JSON, but also can push the projection into a SupportsProjectionPushDown.
class	ReadingMetadataSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the metadata columns to/from JSON, but also can read the metadata columns from SupportsReadingMetadata.
class	SourceAbilitySpecBase Base class for SourceAbilitySpec.
class	SourceWatermarkSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the boolean flag whether a source watermark should be used to/from JSON, but can also apply it to SupportsSourceWatermark.
class	WatermarkPushDownSpec A sub-class of SourceAbilitySpec that can not only serialize/deserialize the watermark to/from JSON, but also can push the watermark into a SupportsWatermarkPushDown.

Uses of SourceAbilitySpec in org.apache.flink.table.planner.plan.nodes.exec.spec

Methods in org.apache.flink.table.planner.plan.nodes.exec.spec that return types with arguments of type SourceAbilitySpec

Modifier and Type	Method and Description
List<SourceAbilitySpec>	DynamicTableSourceSpec.getSourceAbilities()

Constructor parameters in org.apache.flink.table.planner.plan.nodes.exec.spec with type arguments of type SourceAbilitySpec

Constructor and Description
DynamicTableSourceSpec(org.apache.flink.table.catalog.ContextResolvedTable contextResolvedTable, List<SourceAbilitySpec> sourceAbilities)

Uses of SourceAbilitySpec in org.apache.flink.table.planner.plan.reuse

Methods in org.apache.flink.table.planner.plan.reuse with type parameters of type SourceAbilitySpec

Modifier and Type	Method and Description
static <T extends SourceAbilitySpec> T	ScanReuserUtils.getAbilitySpec(SourceAbilitySpec[] abilitySpecs, Class<T> specClass)

Methods in org.apache.flink.table.planner.plan.reuse that return types with arguments of type SourceAbilitySpec

Modifier and Type	Method and Description
static List<SourceAbilitySpec>	ScanReuserUtils.abilitySpecsWithoutEscaped(TableSourceTable table) Returns a list of SourceAbilitySpec instances associated with a given TableSourceTable instance, excluding some particular abilities, such as ProjectPushDownSpec.

Methods in org.apache.flink.table.planner.plan.reuse with parameters of type SourceAbilitySpec

Modifier and Type	Method and Description
static <T extends SourceAbilitySpec> T	ScanReuserUtils.getAbilitySpec(SourceAbilitySpec[] abilitySpecs, Class<T> specClass)
static boolean	ScanReuserUtils.isEscapeDigest(SourceAbilitySpec spec)