Interface SourceBuilder.TimestampedSourceBuffer<T>

Type Parameters:
T - type of the emitted item
All Superinterfaces:
SourceBuilder.SourceBuffer<T>
Enclosing class:
SourceBuilder<C>

public static interface SourceBuilder.TimestampedSourceBuffer<T> extends SourceBuilder.SourceBuffer<T>
The buffer object that the fillBufferFn gets on each call. Used in sources that emit timestamped items.

This class isn't thread-safe.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    add(T item)
    Adds an item to the buffer, assigning System.currentTimeMillis() to it as the timestamp.
    void
    add(T item, long timestamp)
    Adds an item to the buffer, assigning a timestamp to it.

    Methods inherited from interface com.hazelcast.jet.pipeline.SourceBuilder.SourceBuffer

    close, size
  • Method Details

    • add

      void add(@Nonnull T item, long timestamp)
      Adds an item to the buffer, assigning a timestamp to it. The timestamp is in milliseconds.
    • add

      default void add(@Nonnull T item)
      Adds an item to the buffer, assigning System.currentTimeMillis() to it as the timestamp.

      Since this class isn't thread-safe, you can call this method only on the thread on which you received its instance from Jet.

      Specified by:
      add in interface SourceBuilder.SourceBuffer<T>