org.apache.paimon.flink.action.cdc

Class SyncTableActionFactoryBase

java.lang.Object

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

org.apache.paimon.flink.action.cdc.SyncTableActionFactoryBase

All Implemented Interfaces:

Factory, ActionFactory

Direct Known Subclasses:

KafkaSyncTableActionFactory, MongoDBSyncTableActionFactory, MySqlSyncTableActionFactory, PostgresSyncTableActionFactory, PulsarSyncTableActionFactory

public abstract class SyncTableActionFactoryBase
extends SynchronizationActionFactoryBase<SyncTableActionBase>

Base ActionFactory for synchronizing into one Paimon table.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.api.java.tuple.Tuple3<String,String,String>	tablePath

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

Method Summary

Modifier and Type	Method and Description
Optional<Action>	create(MultipleParameterToolAdapter params)
protected void	withParams(MultipleParameterToolAdapter params, SyncTableActionBase 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

tablePath

protected org.apache.flink.api.java.tuple.Tuple3<String,String,String> tablePath

Constructor Detail

SyncTableActionFactoryBase

public SyncTableActionFactoryBase()

Method Detail

create

public Optional<Action> create(MultipleParameterToolAdapter params)

Specified by:

create in interface ActionFactory

Overrides:

create in class SynchronizationActionFactoryBase<SyncTableActionBase>

withParams

protected void withParams(MultipleParameterToolAdapter params,
                          SyncTableActionBase action)

Specified by:

withParams in class SynchronizationActionFactoryBase<SyncTableActionBase>