org.apache.flink.table.planner.plan.nodes.exec.utils

Class CommonPythonUtil

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.utils.CommonPythonUtil

public class CommonPythonUtil
extends Object

A utility class used in PyFlink.

Method Summary

Modifier and Type	Method and Description
static PythonFunctionInfo	createPythonFunctionInfo(org.apache.calcite.rex.RexCall pythonRexCall, Map<org.apache.calcite.rex.RexNode,Integer> inputNodes, ClassLoader classLoader)
static DataViewSpec[]	extractDataViewSpecs(int index, DataType accType)
static Tuple2<PythonAggregateFunctionInfo[],DataViewSpec[][]>	extractPythonAggregateFunctionInfos(org.apache.flink.table.planner.plan.utils.AggregateInfoList pythonAggregateInfoList, org.apache.calcite.rel.core.AggregateCall[] aggCalls)
static Tuple2<int[],PythonFunctionInfo[]>	extractPythonAggregateFunctionInfosFromAggregateCall(org.apache.calcite.rel.core.AggregateCall[] aggCalls)
static Configuration	extractPythonConfiguration(ReadableConfig tableConfig, ClassLoader classLoader)
static boolean	isPythonWorkerInProcessMode(Configuration config, ClassLoader classLoader)
static boolean	isPythonWorkerUsingManagedMemory(Configuration config, ClassLoader classLoader)
static Class<?>	loadClass(String className, ClassLoader classLoader)

Methods inherited from class java.lang.Object

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

Method Detail

loadClass

public static Class<?> loadClass(String className,
                                 ClassLoader classLoader)

extractPythonConfiguration

public static Configuration extractPythonConfiguration(ReadableConfig tableConfig,
                                                       ClassLoader classLoader)

createPythonFunctionInfo

public static PythonFunctionInfo createPythonFunctionInfo(org.apache.calcite.rex.RexCall pythonRexCall,
                                                          Map<org.apache.calcite.rex.RexNode,Integer> inputNodes,
                                                          ClassLoader classLoader)

isPythonWorkerUsingManagedMemory

public static boolean isPythonWorkerUsingManagedMemory(Configuration config,
                                                       ClassLoader classLoader)

isPythonWorkerInProcessMode

public static boolean isPythonWorkerInProcessMode(Configuration config,
                                                  ClassLoader classLoader)

extractPythonAggregateFunctionInfos

public static Tuple2<PythonAggregateFunctionInfo[],DataViewSpec[][]> extractPythonAggregateFunctionInfos(org.apache.flink.table.planner.plan.utils.AggregateInfoList pythonAggregateInfoList,
                                                                                                         org.apache.calcite.rel.core.AggregateCall[] aggCalls)

extractPythonAggregateFunctionInfosFromAggregateCall

public static Tuple2<int[],PythonFunctionInfo[]> extractPythonAggregateFunctionInfosFromAggregateCall(org.apache.calcite.rel.core.AggregateCall[] aggCalls)

extractDataViewSpecs

public static DataViewSpec[] extractDataViewSpecs(int index,
                                                  DataType accType)