Package 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.
This class isn't thread-safe.
-
Method Summary
Methods inherited from interface com.hazelcast.jet.pipeline.SourceBuilder.SourceBuffer
close, size
-
Method Details
-
add
Adds an item to the buffer, assigning a timestamp to it. The timestamp is in milliseconds. -
add
Adds an item to the buffer, assigningSystem.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 interfaceSourceBuilder.SourceBuffer<T>
-