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

Class RowLevelUpdateSpec

java.lang.Object

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

All Implemented Interfaces:

SinkAbilitySpec

public class RowLevelUpdateSpec
extends Object
implements SinkAbilitySpec

A sub-class of SinkAbilitySpec that can not only serialize/deserialize the row-level update mode, columns & required physical column indices to/from JSON, but also can update existing data for SupportsRowLevelUpdate.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_REQUIRED_PHYSICAL_COLUMN_INDICES
static String	FIELD_NAME_ROW_LEVEL_UPDATE_MODE
static String	FIELD_NAME_UPDATED_COLUMNS

Constructor Summary

Constructors

Constructor and Description
RowLevelUpdateSpec(List<Column> updatedColumns, SupportsRowLevelUpdate.RowLevelUpdateMode rowLevelUpdateMode, RowLevelModificationScanContext scanContext, int[] requiredPhysicalColumnIndices)

Method Summary

Modifier and Type	Method and Description
void	apply(DynamicTableSink tableSink) Apply the ability to the given DynamicTableSink.
boolean	equals(Object o)
int[]	getRequiredPhysicalColumnIndices()
SupportsRowLevelUpdate.RowLevelUpdateMode	getRowLevelUpdateMode()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_UPDATED_COLUMNS

public static final String FIELD_NAME_UPDATED_COLUMNS

See Also:

Constant Field Values

FIELD_NAME_ROW_LEVEL_UPDATE_MODE

public static final String FIELD_NAME_ROW_LEVEL_UPDATE_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

RowLevelUpdateSpec

public RowLevelUpdateSpec(@Nonnull
                          List<Column> updatedColumns,
                          @Nonnull
                          SupportsRowLevelUpdate.RowLevelUpdateMode rowLevelUpdateMode,
                          @Nullable
                          RowLevelModificationScanContext scanContext,
                          @Nonnull
                          int[] requiredPhysicalColumnIndices)

Method Detail

apply

public void apply(DynamicTableSink tableSink)

Description copied from interface: SinkAbilitySpec

Apply the ability to the given DynamicTableSink.

Specified by:

apply in interface SinkAbilitySpec

getRowLevelUpdateMode

@Nonnull
public SupportsRowLevelUpdate.RowLevelUpdateMode getRowLevelUpdateMode()

getRequiredPhysicalColumnIndices

public int[] getRequiredPhysicalColumnIndices()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object