Package com.hazelcast.jet.python

Interface PythonExtension

All Superinterfaces:

BatchStage.StageExtension<String,PythonExtension.PythonStage<BatchStage<String>>>, StreamStage.StageExtension<String,PythonExtension.PythonStage<StreamStage<String>>>

public interface PythonExtension
extends StreamStage.StageExtension<String,PythonExtension.PythonStage<StreamStage<String>>>, BatchStage.StageExtension<String,PythonExtension.PythonStage<BatchStage<String>>>

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

Since:

5.7

See Also:

• PythonTransforms

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	PythonExtension.PythonStage<S extends GeneralStage<String>>	Pipeline stage with ability to call Python user-defined functions.

Method Summary

Static Methods

Modifier and Type	Method	Description
static PythonExtension	python()	Extends Pipeline stage with ability to call Python user-defined functions

Methods inherited from interface com.hazelcast.jet.pipeline.BatchStage.StageExtension

extend

Methods inherited from interface com.hazelcast.jet.pipeline.StreamStage.StageExtension

extend

Method Details

python

@Nonnull
static PythonExtension python()

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

Returns:

extension implementation