Package | Description |
---|---|
org.apache.flink.client.python | |
org.apache.flink.table.functions.python | |
org.apache.flink.table.functions.python.utils |
Modifier and Type | Method and Description |
---|---|
static PythonFunction |
PythonFunctionFactory.getPythonFunction(String fullyQualifiedName,
ReadableConfig config)
Returns PythonFunction according to the fully qualified name of the Python UDF i.e
${moduleName}.${functionName} or ${moduleName}.${className}.
|
PythonFunction |
PythonFunctionFactory.getPythonFunction(String moduleName,
String objectName)
Returns PythonFunction according to moduleName and objectName.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonScalarFunction
The wrapper of user defined python scalar function.
|
class |
PythonTableFunction
The wrapper of user defined python table function.
|
Modifier and Type | Method and Description |
---|---|
PythonFunction |
PythonFunctionInfo.getPythonFunction() |
Constructor and Description |
---|
PythonFunctionInfo(PythonFunction pythonFunction,
Object[] inputs) |
Modifier and Type | Method and Description |
---|---|
static PythonFunction |
PythonFunctionUtils.getPythonFunction(String fullyQualifiedName,
ReadableConfig config) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.