Interface SourceBuilder.TimestampedSourceBuffer<T>

  • Type Parameters:
    T - type of the emitted item
    All Superinterfaces:
    Enclosing class:

    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 Detail

      • 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>