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.

C

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

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

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.

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

Returns the name of the handler function.

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

Returns the handler module name.

M

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

Deprecated.

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.

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

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

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

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

P

PythonServiceConfig - Class in com.hazelcast.jet.python

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

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

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