public final class OverwriteSpec extends Object implements SinkAbilitySpec
SinkAbilitySpec that can not only serialize/deserialize the overwrite flag
to/from JSON, but also can overwrite existing data for SupportsOverwrite.| 限定符和类型 | 字段和说明 |
|---|---|
static String |
FIELD_NAME_OVERWRITE |
| 构造器和说明 |
|---|
OverwriteSpec(boolean overwrite) |
public void apply(org.apache.flink.table.connector.sink.DynamicTableSink tableSink)
SinkAbilitySpecDynamicTableSink.apply 在接口中 SinkAbilitySpecCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.