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

Modifier and Type	Method	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 Details

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.

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 interface SourceBuilder.SourceBuffer<T>