Package io.deephaven.stream

Interface StreamConsumer

All Superinterfaces:

StreamFailureConsumer

All Known Implementing Classes:

StreamToBlinkTableAdapter

public interface StreamConsumer
extends StreamFailureConsumer

Chunk-oriented consumer for streams of data.

Method Summary

Modifier and Type	Method	Description
void	accept(@NotNull WritableChunk<Values>... data)	Accept a batch of rows splayed across per-column chunks of values.
void	accept(@NotNull Collection<WritableChunk<Values>[]> data)	Accept a collection of batches of rows splayed across per-column chunks of values.

Methods inherited from interface io.deephaven.stream.StreamFailureConsumer

acceptFailure

Method Details

accept

void accept(@NotNull
 @NotNull WritableChunk<Values>... data)

Accept a batch of rows splayed across per-column chunks of values.

Ownership of data passes to the consumer, which must be sure to close each chunk when it's no longer needed.

Implementations will generally have a mechanism for determining the expected number and type of input chunks, but this is not dictated at the interface level.

Parameters:

data - Per-column chunks of values. Must all have the same size.

accept

void accept(@NotNull
 @NotNull Collection<WritableChunk<Values>[]> data)

Accept a collection of batches of rows splayed across per-column chunks of values.

Ownership of all the chunks contained within data passes to the consumer, which must be sure to close each chunk when it's no longer needed.

Implementations will generally have a mechanism for determining the expected number and type of input chunks for each element, but this is not dictated at the interface level.

Implementations may provide more specific semantics about this method in comparison to repeated invocations of accept(WritableChunk[]).

Parameters:

data - A collection of per-column chunks of values. All chunks in each element must have the same size, but different elements may have differing chunk sizes.