T
- type of the emitted itempublic static interface SourceBuilder.SourceBuffer<T>
fillBufferFn
gets on each call. Used
in sources that emit items without a timestamp.
This class isn't thread-safe.
Modifier and Type | Method and Description |
---|---|
void |
add(T item)
Adds an item to the buffer.
|
void |
close()
Closes the buffer, signaling that all items have been emitted.
|
int |
size()
Returns the number of items the buffer holds.
|
int size()
void close() throws JetException
JetException
- if the source is a streaming sourceCopyright © 2022 Hazelcast, Inc.. All rights reserved.