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

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.

Method Detail

size

int size()

Returns the number of items the buffer holds.

close

void close()
    throws JetException

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

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.