org.apache.paimon.flink.procedure

Class ProcedureBase

java.lang.Object

org.apache.paimon.flink.procedure.ProcedureBase

All Implemented Interfaces:

org.apache.flink.table.procedures.Procedure, Factory

Direct Known Subclasses:

CloneProcedure, CompactDatabaseProcedure, CompactManifestProcedure, CompactProcedure, CreateBranchProcedure, CreateOrReplaceTagBaseProcedure, CreateTagFromTimestampProcedure, CreateTagFromWatermarkProcedure, DeleteBranchProcedure, DeleteTagProcedure, DropPartitionProcedure, ExpirePartitionsProcedure, ExpireSnapshotsProcedure, ExpireTagsProcedure, FastForwardProcedure, InitFileBasedPrivilegeProcedure, MarkPartitionDoneProcedure, MergeIntoProcedure, MigrateDatabaseProcedure, MigrateFileProcedure, MigrateTableProcedure, PrivilegeProcedureBase, QueryServiceProcedure, RefreshObjectTableProcedure, RemoveOrphanFilesProcedure, RenameTagProcedure, RepairProcedure, ResetConsumerProcedure, RewriteFileIndexProcedure, RollbackToProcedure, RollbackToTimestampProcedure

public abstract class ProcedureBase
extends Object
implements org.apache.flink.table.procedures.Procedure, Factory

Base implementation for flink Procedure.

Field Summary

Fields

Modifier and Type	Field and Description
protected Catalog	catalog

Constructor Summary

Constructors

Constructor and Description
ProcedureBase()

Method Summary

Modifier and Type	Method and Description
protected String[]	execute(org.apache.flink.table.procedure.ProcedureContext procedureContext, ActionBase action, String defaultJobName)
protected String[]	execute(org.apache.flink.table.procedure.ProcedureContext procedureContext, org.apache.flink.core.execution.JobClient jobClient)
protected String[]	execute(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String defaultJobName)
protected String	notnull(String arg)
protected String	nullable(String arg)
protected Map<String,String>	optionalConfigMap(String configStr)
protected Table	table(String tableId)
ProcedureBase	withCatalog(Catalog catalog)

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.factories.Factory

identifier

Field Detail

catalog

protected Catalog catalog

Constructor Detail

ProcedureBase

public ProcedureBase()

Method Detail

withCatalog

public ProcedureBase withCatalog(Catalog catalog)

table

protected Table table(String tableId)
               throws Catalog.TableNotExistException

Throws:

Catalog.TableNotExistException

notnull

protected String notnull(@Nullable
                         String arg)

nullable

@Nullable
protected String nullable(String arg)

execute

protected String[] execute(org.apache.flink.table.procedure.ProcedureContext procedureContext,
                           ActionBase action,
                           String defaultJobName)
                    throws Exception

Throws:

Exception

execute

protected String[] execute(org.apache.flink.table.procedure.ProcedureContext procedureContext,
                           org.apache.flink.core.execution.JobClient jobClient)

execute

protected String[] execute(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
                           String defaultJobName)
                    throws Exception

Throws:

Exception

optionalConfigMap

protected Map<String,String> optionalConfigMap(String configStr)