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

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(com.hazelcast.function.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
S	PythonExtension.PythonStage.map(PythonServiceConfig cfg)	Adds a "map using Python" pipeline stage.
static <K> com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<String>,com.hazelcast.jet.pipeline.StreamStage<String>>	PythonTransforms.mapUsingPython(com.hazelcast.function.FunctionEx<? super String,? extends K> keyFn, PythonServiceConfig cfg)	Deprecated, for removal: This API element is subject to removal in a future version. Jet now has first-class support for data rebalancing, see GeneralStage.rebalance() and GeneralStage.rebalance(FunctionEx).
static com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<String>,com.hazelcast.jet.pipeline.StreamStage<String>>	PythonTransforms.mapUsingPython(PythonServiceConfig cfg)	A stage-transforming method that adds a "map using Python" pipeline stage.
static com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<String>,com.hazelcast.jet.pipeline.StreamStage<String>>	PythonTransforms.mapUsingPython(PythonServiceConfig cfg, int maxBatchSize)	A stage-transforming method that adds a "map using Python" pipeline stage.
static <K> com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.BatchStage<String>,com.hazelcast.jet.pipeline.BatchStage<String>>	PythonTransforms.mapUsingPythonBatch(com.hazelcast.function.FunctionEx<? super String,? extends K> keyFn, PythonServiceConfig cfg)	Deprecated, for removal: This API element is subject to removal in a future version. Jet now has first-class support for data rebalancing, see GeneralStage.rebalance() and GeneralStage.rebalance(FunctionEx).
static com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.BatchStage<String>,com.hazelcast.jet.pipeline.BatchStage<String>>	PythonTransforms.mapUsingPythonBatch(PythonServiceConfig cfg)	A stage-transforming method that adds a "map using Python" pipeline stage.
static com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.BatchStage<String>,com.hazelcast.jet.pipeline.BatchStage<String>>	PythonTransforms.mapUsingPythonBatch(PythonServiceConfig cfg, int maxBatchSize)	A stage-transforming method that adds a "map using Python" pipeline stage.