Uses of Class
org.apache.flink.table.functions.python.PythonFunctionInfo

Packages that use PythonFunctionInfo

Package	Description
org.apache.flink.python.util
org.apache.flink.streaming.api.functions.python
org.apache.flink.table.functions.python
org.apache.flink.table.planner.plan.nodes.exec.utils
org.apache.flink.table.runtime.operators.python.aggregate.arrow
org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.scalar.arrow
org.apache.flink.table.runtime.operators.python.table

Uses of PythonFunctionInfo in org.apache.flink.python.util

Methods in org.apache.flink.python.util with parameters of type PythonFunctionInfo

Modifier and Type	Method and Description
static FlinkFnApi.UserDefinedFunction	ProtoUtils.createUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)
static FlinkFnApi.UserDefinedFunctions	ProtoUtils.createUserDefinedFunctionsProto(PythonFunctionInfo[] userDefinedFunctions, boolean isMetricEnabled, boolean isProfileEnabled)

Uses of PythonFunctionInfo in org.apache.flink.streaming.api.functions.python

Subclasses of PythonFunctionInfo in org.apache.flink.streaming.api.functions.python

Modifier and Type	Class and Description
class	DataStreamPythonFunctionInfo DataStreamPythonFunctionInfo holds a PythonFunction and its function type.

Uses of PythonFunctionInfo in org.apache.flink.table.functions.python

Subclasses of PythonFunctionInfo in org.apache.flink.table.functions.python

Modifier and Type	Class and Description
class	PythonAggregateFunctionInfo PythonAggregateFunctionInfo contains the execution information of a Python aggregate function, such as: the actual Python aggregation function, the input arguments, the filter arg, the distinct flag, etc.

Uses of PythonFunctionInfo in org.apache.flink.table.planner.plan.nodes.exec.utils

Methods in org.apache.flink.table.planner.plan.nodes.exec.utils that return PythonFunctionInfo

Modifier and Type	Method and Description
static PythonFunctionInfo	CommonPythonUtil.createPythonFunctionInfo(org.apache.calcite.rex.RexCall pythonRexCall, Map<org.apache.calcite.rex.RexNode,Integer> inputNodes, ClassLoader classLoader)

Uses of PythonFunctionInfo in org.apache.flink.table.runtime.operators.python.aggregate.arrow

Fields in org.apache.flink.table.runtime.operators.python.aggregate.arrow declared as PythonFunctionInfo

Modifier and Type	Field and Description
protected PythonFunctionInfo[]	AbstractArrowPythonAggregateFunctionOperator.pandasAggFunctions The Pandas AggregateFunctions to be executed.

Constructors in org.apache.flink.table.runtime.operators.python.aggregate.arrow with parameters of type PythonFunctionInfo

Constructor and Description
AbstractArrowPythonAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, GeneratedProjection udafInputGeneratedProjection)

Uses of PythonFunctionInfo in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch

Constructors in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch with parameters of type PythonFunctionInfo

Constructor and Description
BatchArrowPythonGroupAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, GeneratedProjection inputGeneratedProjection, GeneratedProjection groupKeyGeneratedProjection, GeneratedProjection groupSetGeneratedProjection)
BatchArrowPythonGroupWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, int maxLimitSize, long windowSize, long slideSize, int[] namedProperties, GeneratedProjection inputGeneratedProjection, GeneratedProjection groupKeyGeneratedProjection, GeneratedProjection groupSetGeneratedProjection)
BatchArrowPythonOverWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, long[] lowerBoundary, long[] upperBoundary, boolean[] isRangeWindows, int[] aggWindowIndex, int inputTimeFieldIndex, boolean asc, GeneratedProjection inputGeneratedProjection, GeneratedProjection groupKeyGeneratedProjection, GeneratedProjection groupSetGeneratedProjection)

Uses of PythonFunctionInfo in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream

Constructors in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream with parameters of type PythonFunctionInfo

Constructor and Description
AbstractStreamArrowPythonBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection inputGeneratedProjection)
AbstractStreamArrowPythonBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection inputGeneratedProjection)
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection inputGeneratedProjection)
StreamArrowPythonGroupWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, WindowAssigner<W> windowAssigner, Trigger<W> trigger, long allowedLateness, NamedWindowProperty[] namedProperties, java.time.ZoneId shiftTimeZone, GeneratedProjection generatedProjection)
StreamArrowPythonProcTimeBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection generatedProjection)
StreamArrowPythonProcTimeBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection inputGeneratedProjection)
StreamArrowPythonRowTimeBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection generatedProjection)
StreamArrowPythonRowTimeBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int inputTimeFieldIndex, long lowerBoundary, GeneratedProjection inputGeneratedProjection)

Uses of PythonFunctionInfo in org.apache.flink.table.runtime.operators.python.scalar

Fields in org.apache.flink.table.runtime.operators.python.scalar declared as PythonFunctionInfo

Modifier and Type	Field and Description
protected PythonFunctionInfo[]	AbstractPythonScalarFunctionOperator.scalarFunctions The Python ScalarFunctions to be executed.

Constructors in org.apache.flink.table.runtime.operators.python.scalar with parameters of type PythonFunctionInfo

Constructor and Description
AbstractPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, GeneratedProjection udfInputGeneratedProjection, GeneratedProjection forwardedFieldGeneratedProjection)
EmbeddedPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, int[] udfInputOffsets, GeneratedProjection forwardedFieldGeneratedProjection)
PythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, GeneratedProjection udfInputGeneratedProjection, GeneratedProjection forwardedFieldGeneratedProjection)

Uses of PythonFunctionInfo in org.apache.flink.table.runtime.operators.python.scalar.arrow

Constructors in org.apache.flink.table.runtime.operators.python.scalar.arrow with parameters of type PythonFunctionInfo

Constructor and Description
ArrowPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType udfInputType, RowType udfOutputType, GeneratedProjection udfInputGeneratedProjection, GeneratedProjection forwardedFieldGeneratedProjection)

Uses of PythonFunctionInfo in org.apache.flink.table.runtime.operators.python.table

Constructors in org.apache.flink.table.runtime.operators.python.table with parameters of type PythonFunctionInfo

Constructor and Description
EmbeddedPythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType udfInputType, RowType udfOutputType, FlinkJoinType joinType, int[] udfInputOffsets)
PythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType udfInputType, RowType udfOutputType, FlinkJoinType joinType, GeneratedProjection udtfInputGeneratedProjection)