Uses of Class
com.hazelcast.jet.python.PythonServiceConfig

Packages that use 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.setChannelFn(BiFunctionEx<String,Integer,? extends io.grpc.ManagedChannelBuilder<?>> channelFn)	Sets the channel function.
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, see GeneralStage.rebalance() and GeneralStage.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 FunctionEx<StreamStage<String>,StreamStage<String>>	PythonTransforms.mapUsingPython(PythonServiceConfig cfg, int maxBatchSize)	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)	Deprecated. Jet now has first-class support for data rebalancing, see GeneralStage.rebalance() and GeneralStage.rebalance(FunctionEx).
static FunctionEx<BatchStage<String>,BatchStage<String>>	PythonTransforms.mapUsingPythonBatch(PythonServiceConfig cfg)	A stage-transforming method that adds a "map using Python" pipeline stage.
static FunctionEx<BatchStage<String>,BatchStage<String>>	PythonTransforms.mapUsingPythonBatch(PythonServiceConfig cfg, int maxBatchSize)	A stage-transforming method that adds a "map using Python" pipeline stage.