Index

B C H M P S V
All Classes and Interfaces|All Packages|Serialized Form

B

baseDir() - Method in class com.hazelcast.jet.python.PythonServiceConfig

Returns the Python base directory.

baseDir(String) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Sets the base directory where the Python files reside.

C

channelFn() - Method in class com.hazelcast.jet.python.PythonServiceConfig

Returns the channel function, see PythonServiceConfig.setChannelFn(com.hazelcast.function.BiFunctionEx<java.lang.String, java.lang.Integer, ? extends io.grpc.ManagedChannelBuilder<?>>).

channelFn(BiFunctionEx<String, Integer, ? extends ManagedChannelBuilder<?>>) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Sets the channel function.

com.hazelcast.jet.python - package 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.

H

handlerFile() - Method in class com.hazelcast.jet.python.PythonServiceConfig

Returns the Python handler file.

handlerFile(String) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Sets the Python handler file.

handlerFunction() - Method in class com.hazelcast.jet.python.PythonServiceConfig

Returns the name of the handler function.

handlerFunction(String) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Overrides the default name of the Python function that transforms Jet pipeline data.

handlerModule() - Method in class com.hazelcast.jet.python.PythonServiceConfig

Returns the handler module name.

handlerModule(String) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Sets the name of the Python module that has the function that transforms Jet pipeline data.

M

map() - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Adds a "map using Python" pipeline stage which uses PythonServiceConfig configured using fluent builder API in this stage.

map(PythonServiceConfig) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Adds a "map using Python" pipeline stage.

mapUsingPython(FunctionEx<? super String, ? extends K>, PythonServiceConfig) - Static method in class com.hazelcast.jet.python.PythonTransforms

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).

mapUsingPython(PythonServiceConfig) - Static method in class com.hazelcast.jet.python.PythonTransforms

A stage-transforming method that adds a "map using Python" pipeline stage.

mapUsingPython(PythonServiceConfig, int) - Static method in class com.hazelcast.jet.python.PythonTransforms

A stage-transforming method that adds a "map using Python" pipeline stage.

mapUsingPythonBatch(FunctionEx<? super String, ? extends K>, PythonServiceConfig) - Static method in class com.hazelcast.jet.python.PythonTransforms

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).

mapUsingPythonBatch(PythonServiceConfig) - Static method in class com.hazelcast.jet.python.PythonTransforms

A stage-transforming method that adds a "map using Python" pipeline stage.

mapUsingPythonBatch(PythonServiceConfig, int) - Static method in class com.hazelcast.jet.python.PythonTransforms

A stage-transforming method that adds a "map using Python" pipeline stage.

maxBatchSize(int) - Method in interface com.hazelcast.jet.python.PythonExtension.PythonStage

Sets the maximum size of a batch for a single request to Python handler.

P

python() - Static method in interface com.hazelcast.jet.python.PythonExtension

Extends Pipeline stage with ability to call Python user-defined functions

PythonExtension - Interface in com.hazelcast.jet.python

Extension which allows the user to call Python user-defined functions from inside a Jet pipeline.

PythonExtension.PythonStage<S extends com.hazelcast.jet.pipeline.GeneralStage<String>> - Interface in com.hazelcast.jet.python

Pipeline stage with ability to call Python user-defined functions.

PythonServiceConfig - Class in com.hazelcast.jet.python

Configuration object for the Python service factory, used in a mapUsingPython stage and python extension.

PythonServiceConfig() - Constructor for class com.hazelcast.jet.python.PythonServiceConfig

Creates empty configuration.

PythonTransforms - Class in com.hazelcast.jet.python

Transforms which allow the user to call Python user-defined functions from inside a Jet pipeline.

S

setBaseDir(String) - Method in class com.hazelcast.jet.python.PythonServiceConfig

Sets the base directory where the Python files reside.

setChannelFn(BiFunctionEx<String, Integer, ? extends ManagedChannelBuilder<?>>) - Method in class com.hazelcast.jet.python.PythonServiceConfig

Sets the channel function.

setHandlerFile(String) - Method in class com.hazelcast.jet.python.PythonServiceConfig

Sets the Python handler file.

setHandlerFunction(String) - Method in class com.hazelcast.jet.python.PythonServiceConfig

Overrides the default name of the Python function that transforms Jet pipeline data.

setHandlerModule(String) - Method in class com.hazelcast.jet.python.PythonServiceConfig

Sets the name of the Python module that has the function that transforms Jet pipeline data.

V

validate() - Method in class com.hazelcast.jet.python.PythonServiceConfig

Validates the configuration and throws an exception if a mandatory config option is missing.

B C H M P S V
All Classes and Interfaces|All Packages|Serialized Form