org.apache.paimon.flink.action.cdc

Class SyncDatabaseActionFactoryBase<T extends SyncDatabaseActionBase>

java.lang.Object

org.apache.paimon.flink.action.cdc.SynchronizationActionFactoryBase<T>

org.apache.paimon.flink.action.cdc.SyncDatabaseActionFactoryBase<T>

All Implemented Interfaces:

Factory, ActionFactory

Direct Known Subclasses:

KafkaSyncDatabaseActionFactory, MongoDBSyncDatabaseActionFactory, MySqlSyncDatabaseActionFactory, PulsarSyncDatabaseActionFactory

public abstract class SyncDatabaseActionFactoryBase<T extends SyncDatabaseActionBase>
extends SynchronizationActionFactoryBase<T>

Base ActionFactory for synchronizing into database.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	database
protected String	warehouse

Fields inherited from class org.apache.paimon.flink.action.cdc.SynchronizationActionFactoryBase

catalogConfig, cdcSourceConfig

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
SyncDatabaseActionFactoryBase()

Method Summary

Modifier and Type	Method and Description
Optional<Action>	create(MultipleParameterToolAdapter params)
protected void	withParams(MultipleParameterToolAdapter params, T action)

Methods inherited from class org.apache.paimon.flink.action.cdc.SynchronizationActionFactoryBase

cdcConfigIdentifier, createAction

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, printHelp

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

identifier

Field Detail

warehouse

protected String warehouse

database

protected String database

Constructor Detail

SyncDatabaseActionFactoryBase

public SyncDatabaseActionFactoryBase()

Method Detail

create

public Optional<Action> create(MultipleParameterToolAdapter params)

Specified by:

create in interface ActionFactory

Overrides:

create in class SynchronizationActionFactoryBase<T extends SyncDatabaseActionBase>

withParams

protected void withParams(MultipleParameterToolAdapter params,
                          T action)

Specified by:

withParams in class SynchronizationActionFactoryBase<T extends SyncDatabaseActionBase>