org.apache.flink.client.python

Class PythonFunctionFactoryImpl

java.lang.Object

org.apache.flink.client.python.PythonFunctionFactoryImpl

All Implemented Interfaces:

Closeable, AutoCloseable, PythonFunctionFactory

public class PythonFunctionFactoryImpl
extends Object
implements PythonFunctionFactory, Closeable

Default implementation of PythonFunctionFactory.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.client.python.PythonFunctionFactory

PythonFunctionFactory.CacheKey

Field Summary

Fields inherited from interface org.apache.flink.client.python.PythonFunctionFactory

CACHE_CLEANUP_EXECUTOR_SERVICE, CACHE_CLEANUP_EXECUTOR_SERVICE_STARTED, PYTHON_FUNCTION_FACTORY_CACHE

Constructor Summary

Constructors

Constructor and Description
PythonFunctionFactoryImpl(PythonFunctionFactory realPythonFunctionFactory, PythonEnvUtils.PythonProcessShutdownHook shutdownHook)

Method Summary

Modifier and Type	Method and Description
void	close()
PythonFunction	getPythonFunction(String moduleName, String objectName) Returns PythonFunction according to moduleName and objectName.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.client.python.PythonFunctionFactory

createPythonFunctionFactory, ensureCacheCleanupExecutorServiceStarted, getPythonFunction

Constructor Detail

PythonFunctionFactoryImpl

public PythonFunctionFactoryImpl(PythonFunctionFactory realPythonFunctionFactory,
                                 PythonEnvUtils.PythonProcessShutdownHook shutdownHook)

Method Detail

getPythonFunction

public PythonFunction getPythonFunction(String moduleName,
                                        String objectName)

Description copied from interface: PythonFunctionFactory

Returns PythonFunction according to moduleName and objectName.

Specified by:

getPythonFunction in interface PythonFunctionFactory

Parameters:

moduleName - The module name of the Python UDF.

objectName - The function name / class name of the Python UDF.

Returns:

The PythonFunction object which represents the Python UDF.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable