- Type Parameters:
T- type of the emitted item
- All Known Subinterfaces:
public static interface SourceBuilder.SourceBuffer<T>The buffer object that the
fillBufferFngets on each call. Used in sources that emit items without a timestamp.
This class isn't thread-safe.
int size()Returns the number of items the buffer holds.
void close() throws JetExceptionCloses the buffer, signaling that all items have been emitted. Only SourceBuilder.batch(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.core.Processor.Context, ? extends C>) sources are allowed to call this method.
JetException- if the source is a streaming source
void add(@Nonnull T item)Adds an item to the buffer.
Since this class isn't thread-safe, you can call this method only on the thread on which you received its instance from Jet.