T
- type of the buffer itempublic static interface SourceBuilder.SourceBuffer<T>
fillBufferFn
gets on each call. Used
in sources that emit items without a timestamp.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.
|
Copyright © 2019 Hazelcast, Inc.. All rights reserved.