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.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 © 2021 Hazelcast, Inc.. All rights reserved.