org.apache.flink.table.planner.operations

Class PlannerCallProcedureOperation

java.lang.Object

org.apache.flink.table.planner.operations.PlannerCallProcedureOperation

All Implemented Interfaces:

org.apache.flink.table.operations.CallProcedureOperation, org.apache.flink.table.operations.ExecutableOperation, org.apache.flink.table.operations.Operation

public class PlannerCallProcedureOperation
extends Object
implements org.apache.flink.table.operations.CallProcedureOperation

Wrapper for valid call procedure operation generated by Planner.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.operations.ExecutableOperation

org.apache.flink.table.operations.ExecutableOperation.Context

Constructor Summary

Constructors

Constructor and Description
PlannerCallProcedureOperation(org.apache.flink.table.catalog.ObjectIdentifier procedureIdentifier, org.apache.flink.table.procedures.Procedure procedure, Object[] internalInputArguments, org.apache.flink.table.types.DataType[] inputTypes, org.apache.flink.table.types.DataType outputType)

Method Summary

Modifier and Type	Method and Description
String	asSummaryString()
org.apache.flink.table.api.internal.TableResultInternal	execute(org.apache.flink.table.operations.ExecutableOperation.Context ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PlannerCallProcedureOperation

public PlannerCallProcedureOperation(org.apache.flink.table.catalog.ObjectIdentifier procedureIdentifier,
                                     org.apache.flink.table.procedures.Procedure procedure,
                                     Object[] internalInputArguments,
                                     org.apache.flink.table.types.DataType[] inputTypes,
                                     org.apache.flink.table.types.DataType outputType)

Method Detail

execute

public org.apache.flink.table.api.internal.TableResultInternal execute(org.apache.flink.table.operations.ExecutableOperation.Context ctx)

Specified by:

execute in interface org.apache.flink.table.operations.ExecutableOperation

asSummaryString

public String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.operations.Operation