T- type of the emitted item
public static interface SourceBuilder.TimestampedSourceBuffer<T> extends SourceBuilder.SourceBuffer<T>
fillBufferFngets on each call. Used in sources that emit timestamped items.
This class isn't thread-safe.
|Modifier and Type||Method and Description|
Adds an item to the buffer, assigning
Adds an item to the buffer, assigning a timestamp to it.
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.
Copyright © 2022 Hazelcast, Inc.. All rights reserved.