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 org.apache.flink.table.functions.python.PythonFunctionInfo	createPythonFunctionInfo(org.apache.calcite.rex.RexCall pythonRexCall, Map<org.apache.calcite.rex.RexNode,Integer> inputNodes, ClassLoader classLoader)
static org.apache.flink.table.runtime.dataview.DataViewSpec[]	extractDataViewSpecs(int index, org.apache.flink.table.types.DataType accType)
static org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.functions.python.PythonAggregateFunctionInfo[],org.apache.flink.table.runtime.dataview.DataViewSpec[][]>	extractPythonAggregateFunctionInfos(AggregateInfoList pythonAggregateInfoList, org.apache.calcite.rel.core.AggregateCall[] aggCalls)
static org.apache.flink.api.java.tuple.Tuple2<int[],org.apache.flink.table.functions.python.PythonFunctionInfo[]>	extractPythonAggregateFunctionInfosFromAggregateCall(org.apache.calcite.rel.core.AggregateCall[] aggCalls)
static org.apache.flink.configuration.Configuration	extractPythonConfiguration(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, org.apache.flink.configuration.ReadableConfig tableConfig, ClassLoader classLoader)
static boolean	isPythonWorkerInProcessMode(org.apache.flink.configuration.Configuration config, ClassLoader classLoader)
static boolean	isPythonWorkerUsingManagedMemory(org.apache.flink.configuration.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 org.apache.flink.configuration.Configuration extractPythonConfiguration(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
                                                                                      org.apache.flink.configuration.ReadableConfig tableConfig,
                                                                                      ClassLoader classLoader)

createPythonFunctionInfo

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

isPythonWorkerUsingManagedMemory

public static boolean isPythonWorkerUsingManagedMemory(org.apache.flink.configuration.Configuration config,
                                                       ClassLoader classLoader)

isPythonWorkerInProcessMode

public static boolean isPythonWorkerInProcessMode(org.apache.flink.configuration.Configuration config,
                                                  ClassLoader classLoader)

extractPythonAggregateFunctionInfos

public static org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.functions.python.PythonAggregateFunctionInfo[],org.apache.flink.table.runtime.dataview.DataViewSpec[][]> extractPythonAggregateFunctionInfos(AggregateInfoList pythonAggregateInfoList,
                                                                                                                                                                                                                         org.apache.calcite.rel.core.AggregateCall[] aggCalls)

extractPythonAggregateFunctionInfosFromAggregateCall

public static org.apache.flink.api.java.tuple.Tuple2<int[],org.apache.flink.table.functions.python.PythonFunctionInfo[]> extractPythonAggregateFunctionInfosFromAggregateCall(org.apache.calcite.rel.core.AggregateCall[] aggCalls)

extractDataViewSpecs

public static org.apache.flink.table.runtime.dataview.DataViewSpec[] extractDataViewSpecs(int index,
                                                                                          org.apache.flink.table.types.DataType accType)