- Type Parameters:
T- type of the emitted item
- All Superinterfaces:
public static interface SourceBuilder.TimestampedSourceBuffer<T> extends SourceBuilder.SourceBuffer<T>
The buffer object that the
fillBufferFngets on each call. Used in sources that emit timestamped items.
This class isn't thread-safe.
addAdds an item to the buffer, assigning a timestamp to it. The timestamp is in milliseconds.
addAdds 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.