com.hazelcast.jet.pipeline

## 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.

- - ### Method Summary

    All Methods Instance Methods Abstract Methods Default Methods
    Modifier and Type | Method and 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 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.
      Specified by:
        `add` in interface `SourceBuilder.SourceBuffer<T>`

Copyright © 2020. All rights reserved.