org.apache.paimon.flink.action

Class ActionBase

java.lang.Object

org.apache.paimon.flink.action.ActionBase

All Implemented Interfaces:

Action

Direct Known Subclasses:

CloneAction, CompactDatabaseAction, CreateTagFromTimestampAction, CreateTagFromWatermarkAction, ExpireSnapshotsAction, ExpireTagsAction, MigrateDatabaseAction, MigrateFileAction, MigrateTableAction, RemoveOrphanFilesAction, RepairAction, RewriteFileIndexAction, SynchronizationActionBase, TableActionBase

public abstract class ActionBase
extends Object
implements Action

Abstract base of Action for table.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.table.api.bridge.java.StreamTableEnvironment	batchTEnv
protected Catalog	catalog
protected String	catalogName
protected Options	catalogOptions
protected org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	env
protected FlinkCatalog	flinkCatalog

Constructor Summary

Constructors

Constructor and Description
ActionBase(String warehouse, Map<String,String> catalogConfig)

Method Summary

Modifier and Type	Method and Description
Map<String,String>	catalogConfig()
protected Catalog.Loader	catalogLoader()
protected boolean	compatibleCheck(List<DataType> actualTypes, List<DataType> expectedTypes) Check whether each DataType of actualTypes is compatible with that of expectedTypes respectively.
protected void	execute(String defaultName)
protected FlinkCatalog	initFlinkCatalog()
protected void	initFlinkEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
protected Catalog	initPaimonCatalog()
protected List<DataType>	toPaimonTypes(List<org.apache.flink.table.types.DataType> flinkDataTypes) Extract LogicalTypes from Flink DataTypes and convert to Paimon DataTypes.
ActionBase	withStreamExecutionEnvironment(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

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.Action

build, run

Field Detail

catalogOptions

protected final Options catalogOptions

catalog

protected final Catalog catalog

flinkCatalog

protected final FlinkCatalog flinkCatalog

catalogName

protected final String catalogName

env

protected org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env

batchTEnv

protected org.apache.flink.table.api.bridge.java.StreamTableEnvironment batchTEnv

Constructor Detail

ActionBase

public ActionBase(String warehouse,
                  Map<String,String> catalogConfig)

Method Detail

withStreamExecutionEnvironment

public ActionBase withStreamExecutionEnvironment(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

initPaimonCatalog

protected Catalog initPaimonCatalog()

initFlinkCatalog

protected FlinkCatalog initFlinkCatalog()

initFlinkEnv

protected void initFlinkEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

execute

protected void execute(String defaultName)
                throws Exception

Throws:

Exception

catalogLoader

protected Catalog.Loader catalogLoader()

toPaimonTypes

protected List<DataType> toPaimonTypes(List<org.apache.flink.table.types.DataType> flinkDataTypes)

Extract LogicalTypes from Flink DataTypes and convert to Paimon DataTypes.

compatibleCheck

protected boolean compatibleCheck(List<DataType> actualTypes,
                                  List<DataType> expectedTypes)

Check whether each DataType of actualTypes is compatible with that of expectedTypes respectively.

catalogConfig

@VisibleForTesting
public Map<String,String> catalogConfig()