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

接口 SinkAbilitySpec

所有已知实现类:

OverwriteSpec, PartitioningSpec, 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.

方法概要

限定符和类型	方法和说明
void	apply(org.apache.flink.table.connector.sink.DynamicTableSink tableSink) Apply the ability to the given DynamicTableSink.

方法详细资料

apply

void apply(org.apache.flink.table.connector.sink.DynamicTableSink tableSink)

Apply the ability to the given DynamicTableSink.