Uses of Class
com.hazelcast.jet.python.PythonServiceConfig
Package
Description
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
Modifier and TypeMethodDescriptionPythonServiceConfig.setBaseDir
(String baseDir) Sets the base directory where the Python files reside.PythonServiceConfig.setChannelFn
(BiFunctionEx<String, Integer, ? extends io.grpc.ManagedChannelBuilder<?>> channelFn) Sets the channel function.PythonServiceConfig.setHandlerFile
(String handlerFile) Sets the Python handler file.PythonServiceConfig.setHandlerFunction
(String handlerFunction) Overrides the default name of the Python function that transforms Jet pipeline data.PythonServiceConfig.setHandlerModule
(String handlerModule) Sets the name of the Python module that has the function that transforms Jet pipeline data.Modifier and TypeMethodDescriptionstatic <K> FunctionEx<StreamStage<String>,
StreamStage<String>> PythonTransforms.mapUsingPython
(FunctionEx<? super String, ? extends K> keyFn, PythonServiceConfig cfg) Deprecated.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.
GeneralStage.rebalance()
andGeneralStage.rebalance(FunctionEx)
.