Uses of Class
com.hazelcast.jet.python.PythonServiceConfig
Package | Description |
---|---|
com.hazelcast.jet.python |
Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function. |
-
Uses of PythonServiceConfig in com.hazelcast.jet.python
Methods in com.hazelcast.jet.python that return PythonServiceConfig Modifier and Type Method Description PythonServiceConfig
PythonServiceConfig. setBaseDir(String baseDir)
Sets the base directory where the Python files reside.PythonServiceConfig
PythonServiceConfig. setHandlerFile(String handlerFile)
Sets the Python handler file.PythonServiceConfig
PythonServiceConfig. setHandlerFunction(String handlerFunction)
Overrides the default name of the Python function that transforms Jet pipeline data.PythonServiceConfig
PythonServiceConfig. setHandlerModule(String handlerModule)
Sets the name of the Python module that has the function that transforms Jet pipeline data.Methods in com.hazelcast.jet.python with parameters of type PythonServiceConfig Modifier and Type Method Description static <K> FunctionEx<StreamStage<String>,StreamStage<String>>
PythonTransforms. mapUsingPython(FunctionEx<? super String,? extends K> keyFn, PythonServiceConfig cfg)
Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()
andGeneralStage.rebalance(FunctionEx)
.static FunctionEx<StreamStage<String>,StreamStage<String>>
PythonTransforms. mapUsingPython(PythonServiceConfig cfg)
A stage-transforming method that adds a "map using Python" pipeline stage.static <K> FunctionEx<BatchStage<String>,BatchStage<String>>
PythonTransforms. mapUsingPythonBatch(FunctionEx<? super String,? extends K> keyFn, PythonServiceConfig cfg)
A stage-transforming method that adds a partitioned "map using Python" pipeline stage.static FunctionEx<BatchStage<String>,BatchStage<String>>
PythonTransforms. mapUsingPythonBatch(PythonServiceConfig cfg)
A stage-transforming method that adds a "map using Python" pipeline stage.