Uses of Interface
org.apache.flink.table.planner.plan.abilities.sink.SinkAbilitySpec

Packages that use SinkAbilitySpec

Package	Description
org.apache.flink.table.planner.plan.abilities.sink
org.apache.flink.table.planner.plan.nodes.exec.spec

Uses of SinkAbilitySpec in org.apache.flink.table.planner.plan.abilities.sink

Classes in org.apache.flink.table.planner.plan.abilities.sink that implement SinkAbilitySpec

Modifier and Type	Class and Description
class	OverwriteSpec A sub-class of SinkAbilitySpec that can not only serialize/deserialize the overwrite flag to/from JSON, but also can overwrite existing data for SupportsOverwrite.
class	PartitioningSpec A sub-class of SinkAbilitySpec that can not only serialize/deserialize the partition to/from JSON, but also can write partitioned data for SupportsPartitioning.
class	RowLevelDeleteSpec A sub-class of SinkAbilitySpec that can not only serialize/deserialize the row-level delete mode & required physical column indices to/from JSON, but also can delete existing data for SupportsRowLevelDelete.
class	RowLevelUpdateSpec A sub-class of SinkAbilitySpec that can not only serialize/deserialize the row-level update mode, columns & required physical column indices to/from JSON, but also can update existing data for SupportsRowLevelUpdate.
class	WritingMetadataSpec A sub-class of SinkAbilitySpec that can not only serialize/deserialize the metadata columns to/from JSON, but also can write the metadata columns for SupportsWritingMetadata.

Uses of SinkAbilitySpec 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 SinkAbilitySpec

Modifier and Type	Method and Description
List<SinkAbilitySpec>	DynamicTableSinkSpec.getSinkAbilities()

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

Constructor and Description
DynamicTableSinkSpec(org.apache.flink.table.catalog.ContextResolvedTable contextResolvedTable, List<SinkAbilitySpec> sinkAbilities, int[][] targetColumns)