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

Packages that use PythonFunctionInfo

Package	Description
org.apache.flink.streaming.api.utils
org.apache.flink.table.functions.python
org.apache.flink.table.runtime.functions.python
org.apache.flink.table.runtime.functions.python.arrow
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.streaming.api.utils

Methods in org.apache.flink.streaming.api.utils with parameters of type PythonFunctionInfo

Modifier and Type	Method and Description
static FlinkFnApi.UserDefinedFunction	PythonOperatorUtils.getUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)

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.runtime.functions.python

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

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

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

Constructor and Description
AbstractPythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
PythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
PythonTableFunctionFlatMap(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)

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

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

Constructor and Description
ArrowPythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)

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 outputType, int[] groupingSet, int[] udafInputOffsets)

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 outputType, int[] groupKey, int[] groupingSet, int[] udafInputOffsets)
BatchArrowPythonGroupWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, int maxLimitSize, long windowSize, long slideSize, int[] namedProperties, int[] groupKey, int[] groupingSet, int[] udafInputOffsets)
BatchArrowPythonOverWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, long[] lowerBoundary, long[] upperBoundary, boolean[] isRangeWindows, int[] aggWindowIndex, int[] groupKey, int[] groupingSet, int[] udafInputOffsets, int inputTimeFieldIndex, boolean asc)

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 outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
AbstractStreamArrowPythonBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonGroupWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, WindowAssigner<W> windowAssigner, Trigger<W> trigger, long allowedLateness, int[] namedProperties, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonProcTimeBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonProcTimeBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonRowTimeBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonRowTimeBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)

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
AbstractRowDataPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
AbstractRowPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
PythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
RowDataPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)

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 outputType, int[] udfInputOffsets, int[] forwardedFields)
RowDataArrowPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)

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

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

Modifier and Type	Field and Description
protected PythonFunctionInfo	AbstractPythonTableFunctionOperator.tableFunction The Python TableFunction to be executed.

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

Constructor and Description
AbstractPythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)
PythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)
RowDataPythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)