Package com.hazelcast.jet.pipeline

Interface BatchSource<T>

Type Parameters:
T - the stream item type
public interface BatchSource<T>
A finite source of data for a Jet pipeline. Finite sources are the only kind that can be used to aggregate data without windowing.
Since:
Jet 3.0
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    name()
    Returns a descriptive name of this source.

  • Method Details

    • name

      @Nonnull String name()
      Returns a descriptive name of this source.