T
- type of the emitted itempublic static interface SourceBuilder.TimestampedSourceBuffer<T> extends SourceBuilder.SourceBuffer<T>
fillBufferFn
gets on each call. Used
in sources that emit timestamped items.
This class isn't thread-safe.
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.
|
close, size
void add(@Nonnull T item, long timestamp)
default void add(@Nonnull T item)
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.
add
in interface SourceBuilder.SourceBuffer<T>
Copyright © 2022 Hazelcast, Inc.. All rights reserved.