Package com.hazelcast.jet.pipeline

Interface BatchStage.StageExtension<T,S>

Type Parameters:
T - the type of items produced by stage to be extended
S - the type implementing additional methods for BatchStage
Enclosing interface:
BatchStage<T>
public static interface BatchStage.StageExtension<T,S>
Extension of BatchStage providing additional capabilities or convenience methods on top of the default stage API using fluent interface.
Since:
5.7

  • Method Summary

    Modifier and Type
    Method
    Description
    S
    extend(BatchStage<T> batchStage)
    Provides additional API to given stage in a fluent way.

  • Method Details

    • extend

      @Nonnull S extend(@Nonnull BatchStage<T> batchStage)
      Provides additional API to given stage in a fluent way.
      Parameters:
      batchStage - stage to be extended
      Returns:
      extended stage