Package com.hazelcast.jet.pipeline
Interface SourceBuilder.SourceBuffer<T>
- Type Parameters:
T
- type of the emitted item
- All Known Subinterfaces:
SourceBuilder.TimestampedSourceBuffer<T>
- Enclosing class:
- SourceBuilder<C>
public static interface SourceBuilder.SourceBuffer<T>
The buffer object that the
fillBufferFn
gets on each call. Used
in sources that emit items without a timestamp.
This class isn't thread-safe.
-
Method Summary
-
Method Details
-
size
int size()Returns the number of items the buffer holds. -
close
Closes 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.- Throws:
JetException
- if the source is a streaming source
-
add
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.
-