Package com.hazelcast.jet.python

Interface PythonExtension

All Superinterfaces:
com.hazelcast.jet.pipeline.BatchStage.StageExtension<String,PythonExtension.PythonStage<com.hazelcast.jet.pipeline.BatchStage<String>>>, com.hazelcast.jet.pipeline.StreamStage.StageExtension<String,PythonExtension.PythonStage<com.hazelcast.jet.pipeline.StreamStage<String>>>
public interface PythonExtension extends com.hazelcast.jet.pipeline.StreamStage.StageExtension<String,PythonExtension.PythonStage<com.hazelcast.jet.pipeline.StreamStage<String>>>, com.hazelcast.jet.pipeline.BatchStage.StageExtension<String,PythonExtension.PythonStage<com.hazelcast.jet.pipeline.BatchStage<String>>>
Extension which allows the user to call Python user-defined functions from inside a Jet pipeline.
Since:
5.7
See Also:

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static interface 
    PythonExtension.PythonStage<S extends com.hazelcast.jet.pipeline.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