org.apache.paimon.flink.action

Interface ActionFactory

All Superinterfaces:

Factory

All Known Implementing Classes:

CloneActionFactory, CompactActionFactory, CompactDatabaseActionFactory, CreateBranchActionFactory, CreateOrReplaceTagActionFactory, CreateTagActionFactory, CreateTagFromTimestampActionFactory, CreateTagFromWatermarkActionFactory, DeleteActionFactory, DeleteBranchActionFactory, DeleteTagActionFactory, DropPartitionActionFactory, ExpirePartitionsActionFactory, ExpireSnapshotsActionFactory, ExpireTagsActionFactory, FastForwardActionFactory, KafkaSyncDatabaseActionFactory, KafkaSyncTableActionFactory, MarkPartitionDoneActionFactory, MergeIntoActionFactory, MigrateDatabaseActionFactory, MigrateFileActionFactory, MigrateTableActionFactory, MongoDBSyncDatabaseActionFactory, MongoDBSyncTableActionFactory, MySqlSyncDatabaseActionFactory, MySqlSyncTableActionFactory, PostgresSyncTableActionFactory, PulsarSyncDatabaseActionFactory, PulsarSyncTableActionFactory, QueryServiceActionFactory, RemoveOrphanFilesActionFactory, RenameTagActionFactory, RepairActionFactory, ReplaceTagActionFactory, ResetConsumerActionFactory, RewriteFileIndexActionFactory, RollbackToActionFactory, RollbackToTimestampActionFactory, SyncDatabaseActionFactoryBase, SynchronizationActionFactoryBase, SyncTableActionFactoryBase

public interface ActionFactory
extends Factory

Factory to create Action.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CATALOG_CONF
static String	COMPACT_STRATEGY
static String	DATABASE
static String	EXPIRATIONTIME
static String	EXPIRE_STRATEGY
static String	FULL
static String	HELP
static org.slf4j.Logger	LOG
static String	MINOR
static String	PARTITION
static String	PATH
static String	TABLE
static String	TABLE_CONF
static String	TIMESTAMP_PATTERN
static String	TIMESTAMPFORMATTER
static String	WAREHOUSE

Method Summary

Modifier and Type	Method and Description
default void	checkRequiredArgument(MultipleParameterToolAdapter params, String key)
Optional<Action>	create(MultipleParameterToolAdapter params)
static Optional<Action>	createAction(String[] args)
default List<Map<String,String>>	getPartitions(MultipleParameterToolAdapter params)
default String	getRequiredValue(MultipleParameterToolAdapter params, String key)
default org.apache.flink.api.java.tuple.Tuple3<String,String,String>	getTablePath(MultipleParameterToolAdapter params)
default Map<String,String>	optionalConfigMap(MultipleParameterToolAdapter params, String key)
default Map<String,List<String>>	optionalConfigMapList(MultipleParameterToolAdapter params, String key)
static void	printDefaultHelp()
void	printHelp()

Methods inherited from interface org.apache.paimon.factories.Factory

identifier

Field Detail

LOG

static final org.slf4j.Logger LOG

HELP

static final String HELP

See Also:

Constant Field Values

WAREHOUSE

static final String WAREHOUSE

See Also:

Constant Field Values

DATABASE

static final String DATABASE

See Also:

Constant Field Values

TABLE

static final String TABLE

See Also:

Constant Field Values

PATH

static final String PATH

See Also:

Constant Field Values

CATALOG_CONF

static final String CATALOG_CONF

See Also:

Constant Field Values

TABLE_CONF

static final String TABLE_CONF

See Also:

Constant Field Values

PARTITION

static final String PARTITION

See Also:

Constant Field Values

EXPIRATIONTIME

static final String EXPIRATIONTIME

See Also:

Constant Field Values

TIMESTAMPFORMATTER

static final String TIMESTAMPFORMATTER

See Also:

Constant Field Values

EXPIRE_STRATEGY

static final String EXPIRE_STRATEGY

See Also:

Constant Field Values

TIMESTAMP_PATTERN

static final String TIMESTAMP_PATTERN

See Also:

Constant Field Values

COMPACT_STRATEGY

static final String COMPACT_STRATEGY

See Also:

Constant Field Values

MINOR

static final String MINOR

See Also:

Constant Field Values

FULL

static final String FULL

See Also:

Constant Field Values

Method Detail

create

Optional<Action> create(MultipleParameterToolAdapter params)

createAction

static Optional<Action> createAction(String[] args)

printHelp

void printHelp()

printDefaultHelp

static void printDefaultHelp()

getTablePath

default org.apache.flink.api.java.tuple.Tuple3<String,String,String> getTablePath(MultipleParameterToolAdapter params)

getPartitions

default List<Map<String,String>> getPartitions(MultipleParameterToolAdapter params)

optionalConfigMap

default Map<String,String> optionalConfigMap(MultipleParameterToolAdapter params,
                                             String key)

checkRequiredArgument

default void checkRequiredArgument(MultipleParameterToolAdapter params,
                                   String key)

getRequiredValue

default String getRequiredValue(MultipleParameterToolAdapter params,
                                String key)

optionalConfigMapList

default Map<String,List<String>> optionalConfigMapList(MultipleParameterToolAdapter params,
                                                       String key)