| 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. | 
| Modifier and Type | Method and 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. 
 | 
| Modifier and Type | Method and 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 <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. 
 | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.