Class OverwriteSpec
- java.lang.Object
-
- org.apache.flink.table.planner.plan.abilities.sink.OverwriteSpec
-
- All Implemented Interfaces:
SinkAbilitySpec
public final class OverwriteSpec extends Object implements SinkAbilitySpec
A sub-class ofSinkAbilitySpec
that can not only serialize/deserialize the overwrite flag to/from JSON, but also can overwrite existing data forSupportsOverwrite
.
-
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_OVERWRITE
-
Constructor Summary
Constructors Constructor Description OverwriteSpec(boolean overwrite)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
apply(DynamicTableSink tableSink)
Apply the ability to the givenDynamicTableSink
.boolean
equals(Object o)
int
hashCode()
-
-
-
Field Detail
-
FIELD_NAME_OVERWRITE
public static final String FIELD_NAME_OVERWRITE
- See Also:
- Constant Field Values
-
-
Method Detail
-
apply
public void apply(DynamicTableSink tableSink)
Description copied from interface:SinkAbilitySpec
Apply the ability to the givenDynamicTableSink
.- Specified by:
apply
in interfaceSinkAbilitySpec
-
-