public interface PythonFunctionFactory
Modifier and Type | Interface and Description |
---|---|
static class |
PythonFunctionFactory.PythonProcessShutdownHook
The shutdown hook used to destroy the Python process.
|
Modifier and Type | Field and Description |
---|---|
static long |
CHECK_INTERVAL |
static AtomicReference<PythonFunctionFactory> |
PYTHON_FUNCTION_FACTORY_REF |
static long |
TIMEOUT_MILLIS |
Modifier and Type | Method and Description |
---|---|
static PythonFunction |
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 |
getPythonFunction(String moduleName,
String objectName)
Returns PythonFunction according to moduleName and objectName.
|
static PythonFunctionFactory |
getPythonFunctionFactory(ReadableConfig config) |
static void |
shutdownPythonProcess(Process pythonProcess,
long timeoutMillis) |
static final long CHECK_INTERVAL
static final long TIMEOUT_MILLIS
static final AtomicReference<PythonFunctionFactory> PYTHON_FUNCTION_FACTORY_REF
PythonFunction getPythonFunction(String moduleName, String objectName)
moduleName
- The module name of the Python UDF.objectName
- The function name / class name of the Python UDF.static PythonFunction getPythonFunction(String fullyQualifiedName, ReadableConfig config) throws IOException, ExecutionException, InterruptedException
fullyQualifiedName
- The fully qualified name of the Python UDF.config
- The configuration of python dependencies.IOException
ExecutionException
InterruptedException
static PythonFunctionFactory getPythonFunctionFactory(ReadableConfig config) throws ExecutionException, InterruptedException, IOException
static void shutdownPythonProcess(Process pythonProcess, long timeoutMillis)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.