Skip to main content
Version: 6.0-SNAPSHOT

Stage Extensions

Stage extensions provide a way to add more capabilities to Pipeline API. They maintain the familiar and convenient fluent API for defining the pipeline. Extensions are applied in the pipeline by using transform.

Builtin extensions​

There are some extensions available in the Hazelcast distribution.

ExtensionModuleBatch/StreamingDescription
PythonExtensionhazelcast-jet-pythonbatch, streamingFluent API for Python invocation
IMapExtension (Enterprise EditionThis feature requires Hazelcast Enterprise, a licensed edition of the Hazelcast Platform.)hazelcast-enterprisebatch, streamingConvenience methods for using IMaps in pipeline transformations

Custom extensions​

It is possible to implement custom extensions. For a tutorial see Create a Custom Stage Extension.