Package com.hazelcast.jet.pipeline

Interface StreamStage.StageExtension<T,S>

Type Parameters:
T - the type of items produced by stage to be extended
S - the type implementing additional methods for StreamStage
Enclosing interface:
StreamStage<T>
public static interface StreamStage.StageExtension<T,S>
Extension of StreamStage 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(StreamStage<T> streamStage)
    Provides additional API to given stage in a fluent way.

  • Method Details

    • extend

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