org.apache.paimon.flink.action

Class TableActionBase

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

All Implemented Interfaces:

Action

Direct Known Subclasses:

CompactAction, CreateBranchAction, CreateTagAction, DeleteAction, DeleteBranchAction, DeleteTagAction, DropPartitionAction, ExpirePartitionsAction, FastForwardAction, MarkPartitionDoneAction, MergeIntoAction, ResetConsumerAction, RollbackToAction

public abstract class TableActionBase
extends ActionBase

Abstract base of Action for table.

Field Summary

Fields

Modifier and Type	Field and Description
protected Identifier	identifier
protected Table	table

Fields inherited from class org.apache.paimon.flink.action.ActionBase

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.api.TableResult	batchSink(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream) Sink DataStream dataStream to table with Flink Table API in batch environment.

Methods inherited from class org.apache.paimon.flink.action.ActionBase

catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment

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

table

protected Table table

identifier

protected final Identifier identifier

Method Detail

batchSink

public org.apache.flink.table.api.TableResult batchSink(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream)

Sink DataStream dataStream to table with Flink Table API in batch environment.