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

Class RowLevelDeleteSpec

java.lang.Object

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

All Implemented Interfaces:

SinkAbilitySpec

public class RowLevelDeleteSpec
extends Object
implements SinkAbilitySpec

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.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_REQUIRED_PHYSICAL_COLUMN_INDICES
static String	FIELD_NAME_ROW_LEVEL_DELETE_MODE

Constructor Summary

Constructors

Constructor and Description
RowLevelDeleteSpec(org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteMode rowLevelDeleteMode, org.apache.flink.table.connector.RowLevelModificationScanContext scanContext, int[] requiredPhysicalColumnIndices)

Method Summary

Modifier and Type	Method and Description
void	apply(org.apache.flink.table.connector.sink.DynamicTableSink tableSink) Apply the ability to the given DynamicTableSink.
boolean	equals(Object o)
int[]	getRequiredPhysicalColumnIndices()
org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteMode	getRowLevelDeleteMode()
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

FIELD_NAME_ROW_LEVEL_DELETE_MODE

public static final String FIELD_NAME_ROW_LEVEL_DELETE_MODE

See Also:

Constant Field Values

FIELD_NAME_REQUIRED_PHYSICAL_COLUMN_INDICES

public static final String FIELD_NAME_REQUIRED_PHYSICAL_COLUMN_INDICES

See Also:

Constant Field Values

Constructor Detail

RowLevelDeleteSpec

public RowLevelDeleteSpec(@Nonnull
                          org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteMode rowLevelDeleteMode,
                          @Nullable
                          org.apache.flink.table.connector.RowLevelModificationScanContext scanContext,
                          @Nonnull
                          int[] requiredPhysicalColumnIndices)

Method Detail

apply

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

Description copied from interface: SinkAbilitySpec

Apply the ability to the given DynamicTableSink.

Specified by:

apply in interface SinkAbilitySpec

getRowLevelDeleteMode

@Nonnull
public org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteMode getRowLevelDeleteMode()

getRequiredPhysicalColumnIndices

public int[] getRequiredPhysicalColumnIndices()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object