Package org.apache.flink.table.operations

Interface ExecutableOperation

All Superinterfaces:

Operation

All Known Subinterfaces:

AlterOperation, CallProcedureOperation, CreateOperation, DropOperation, ShowOperation, UseOperation

All Known Implementing Classes:

AbstractShowOperation, AddJarOperation, AddPartitionsOperation, AlterCatalogCommentOperation, AlterCatalogFunctionOperation, AlterCatalogOptionsOperation, AlterCatalogResetOperation, AlterDatabaseOperation, AlterMaterializedTableChangeOperation, AlterMaterializedTableOperation, AlterMaterializedTableRefreshOperation, AlterMaterializedTableResumeOperation, AlterMaterializedTableSuspendOperation, AlterPartitionOperation, AlterPartitionPropertiesOperation, AlterTableChangeOperation, AlterTableOperation, AlterTableOptionsOperation, AlterTableRenameOperation, AlterTableSchemaOperation, AlterViewAsOperation, AlterViewOperation, AlterViewPropertiesOperation, AlterViewRenameOperation, CreateCatalogFunctionOperation, CreateCatalogOperation, CreateDatabaseOperation, CreateMaterializedTableOperation, CreateTableOperation, CreateTempSystemFunctionOperation, CreateViewOperation, DescribeCatalogOperation, DescribeFunctionOperation, DescribeJobOperation, DescribeTableOperation, DropCatalogFunctionOperation, DropCatalogOperation, DropDatabaseOperation, DropMaterializedTableOperation, DropPartitionsOperation, DropTableOperation, DropTempSystemFunctionOperation, DropViewOperation, LoadModuleOperation, PlannerCallProcedureOperation, ShowCatalogsOperation, ShowColumnsOperation, ShowCreateCatalogOperation, ShowCreateTableOperation, ShowCreateViewOperation, ShowCurrentCatalogOperation, ShowCurrentDatabaseOperation, ShowDatabasesOperation, ShowFunctionsOperation, ShowJarsOperation, ShowJobsOperation, ShowModulesOperation, ShowPartitionsOperation, ShowProceduresOperation, ShowTablesOperation, ShowViewsOperation, TruncateTableOperation, UnloadModuleOperation, UseCatalogOperation, UseDatabaseOperation, UseModulesOperation

@Internal
public interface ExecutableOperation
extends Operation

An ExecutableOperation represents an operation that is executed for its side effects.

This internal interface is proposed to reduce the maintenance of bloated TableEnvironmentImpl.executeInternal(Operation) and improve code readability as execution logic is co-located with the operation definition. Besides, this interface can be used to extend user-defined operation with customized execution logic once this interface is stable and public in the future.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ExecutableOperation.Context	The context to execute the operation.

Method Summary

Modifier and Type	Method	Description
TableResultInternal	execute(ExecutableOperation.Context ctx)	Executes the given operation and return the execution result.

Methods inherited from interface org.apache.flink.table.operations.Operation

asSummaryString

Method Detail

execute

TableResultInternal execute(ExecutableOperation.Context ctx)

Executes the given operation and return the execution result.

Parameters:

ctx - the context to execute the operation.

Returns:

the content of the execution result.

See Also:

TableEnvironmentInternal.executeInternal(Operation)