org.apache.paimon.flink.action

Class MergeIntoActionFactory

java.lang.Object

org.apache.paimon.flink.action.MergeIntoActionFactory

All Implemented Interfaces:

Factory, ActionFactory

public class MergeIntoActionFactory
extends Object
implements ActionFactory

Factory to create MergeIntoAction.

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTIFIER
static String	MATCHED_DELETE
static String	MATCHED_UPSERT
static String	NOT_MATCHED_BY_SOURCE_DELETE
static String	NOT_MATCHED_BY_SOURCE_UPSERT
static String	NOT_MATCHED_INSERT

Fields inherited from interface org.apache.paimon.flink.action.ActionFactory

CATALOG_CONF, DATABASE, EXPIRATIONTIME, EXPIRE_STRATEGY, HELP, LOG, PARTITION, PATH, TABLE, TABLE_CONF, TIMESTAMP_PATTERN, TIMESTAMPFORMATTER, WAREHOUSE

Constructor Summary

Constructors

Constructor and Description
MergeIntoActionFactory()

Method Summary

Modifier and Type	Method and Description
Optional<Action>	create(MultipleParameterToolAdapter params)
String	identifier() Returns a unique identifier among same factory interfaces.
void	printHelp()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.action.ActionFactory

checkRequiredArgument, createAction, getPartitions, getRequiredValue, getTablePath, optionalConfigMap, optionalConfigMapList, printDefaultHelp

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

MATCHED_UPSERT

public static final String MATCHED_UPSERT

See Also:

Constant Field Values

NOT_MATCHED_BY_SOURCE_UPSERT

public static final String NOT_MATCHED_BY_SOURCE_UPSERT

See Also:

Constant Field Values

MATCHED_DELETE

public static final String MATCHED_DELETE

See Also:

Constant Field Values

NOT_MATCHED_BY_SOURCE_DELETE

public static final String NOT_MATCHED_BY_SOURCE_DELETE

See Also:

Constant Field Values

NOT_MATCHED_INSERT

public static final String NOT_MATCHED_INSERT

See Also:

Constant Field Values

Constructor Detail

MergeIntoActionFactory

public MergeIntoActionFactory()

Method Detail

identifier

public String identifier()

Description copied from interface: Factory

Returns a unique identifier among same factory interfaces.

For consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended using "-" (e.g. elasticsearch-7).

Specified by:

identifier in interface Factory

create

public Optional<Action> create(MultipleParameterToolAdapter params)

Specified by:

create in interface ActionFactory

printHelp

public void printHelp()

Specified by:

printHelp in interface ActionFactory