org.apache.paimon.flink.action.cdc

Class SynchronizationActionFactoryBase<T extends SynchronizationActionBase>

java.lang.Object

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

All Implemented Interfaces:

Factory, ActionFactory

Direct Known Subclasses:

SyncDatabaseActionFactoryBase, SyncTableActionFactoryBase

public abstract class SynchronizationActionFactoryBase<T extends SynchronizationActionBase>
extends Object
implements ActionFactory

Base ActionFactory for table/database synchronizing job.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,String>	catalogConfig
protected Map<String,String>	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
SynchronizationActionFactoryBase()

Method Summary

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

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

catalogConfig

protected Map<String,String> catalogConfig

cdcSourceConfig

protected Map<String,String> cdcSourceConfig

Constructor Detail

SynchronizationActionFactoryBase

public SynchronizationActionFactoryBase()

Method Detail

cdcConfigIdentifier

protected abstract String cdcConfigIdentifier()

createAction

public abstract T createAction()

create

public Optional<Action> create(MultipleParameterToolAdapter params)

Specified by:

create in interface ActionFactory

withParams

protected abstract void withParams(MultipleParameterToolAdapter params,
                                   T action)