- 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.
Modifier and Type Method Description
T item)(Adds an item to the buffer.
()Closes the buffer, signaling that all items have been emitted.
()Returns the number of items the buffer holds.
sizeint size()Returns the number of items the buffer holds.
closevoid 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
addAdds 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.