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

Interface SinkAbilitySpec

All Known Implementing Classes:

OverwriteSpec, PartitioningSpec, RowLevelDeleteSpec, RowLevelUpdateSpec, WritingMetadataSpec

@Internal
public interface SinkAbilitySpec

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

Method Summary

Modifier and Type	Method and Description
void	apply(DynamicTableSink tableSink) Apply the ability to the given DynamicTableSink.

Method Detail

apply

void apply(DynamicTableSink tableSink)

Apply the ability to the given DynamicTableSink.