Package io.deephaven.extensions.barrage.chunk

Interface ChunkInputStreamGenerator

All Superinterfaces:

AutoCloseable, SafeCloseable

All Known Implementing Classes:

BaseChunkInputStreamGenerator, BooleanChunkInputStreamGenerator, ByteChunkInputStreamGenerator, CharChunkInputStreamGenerator, DoubleChunkInputStreamGenerator, FloatChunkInputStreamGenerator, IntChunkInputStreamGenerator, LongChunkInputStreamGenerator, ShortChunkInputStreamGenerator, VarBinaryChunkInputStreamGenerator, VarListChunkInputStreamGenerator, VectorChunkInputStreamGenerator

public interface ChunkInputStreamGenerator
extends SafeCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ChunkInputStreamGenerator.BufferListener
static class	ChunkInputStreamGenerator.DrainableColumn
static interface	ChunkInputStreamGenerator.Factory	Creator of ChunkInputStreamGenerator instances.
static final class	ChunkInputStreamGenerator.FieldNodeInfo
static interface	ChunkInputStreamGenerator.FieldNodeListener

Field Summary

Fields

Modifier and Type	Field	Description
static final long	MAX_LOCAL_DATE_VALUE
static final long	MIN_LOCAL_DATE_VALUE
static final long	MS_PER_DAY

Method Summary

Modifier and Type	Method	Description
ChunkInputStreamGenerator.DrainableColumn	getInputStream(StreamReaderOptions options, @Nullable RowSet subset)	Get an input stream optionally position-space filtered using the provided RowSet.
long	getLastRowOffset()	Returns the offset of the final row this generator can produce.
long	getRowOffset()	Returns the number of rows that were sent before the first row in this generator.

Methods inherited from interface io.deephaven.util.SafeCloseable

close

Field Details

MS_PER_DAY

static final long MS_PER_DAY

See Also:

• Constant Field Values

MIN_LOCAL_DATE_VALUE

static final long MIN_LOCAL_DATE_VALUE

See Also:

• Constant Field Values

MAX_LOCAL_DATE_VALUE

static final long MAX_LOCAL_DATE_VALUE

See Also:

• Constant Field Values

Method Details

getRowOffset

long getRowOffset()

Returns the number of rows that were sent before the first row in this generator.

getLastRowOffset

long getLastRowOffset()

Returns the offset of the final row this generator can produce.

getInputStream

ChunkInputStreamGenerator.DrainableColumn getInputStream(StreamReaderOptions options,
 @Nullable
 @Nullable RowSet subset)
                                                  throws IOException

Get an input stream optionally position-space filtered using the provided RowSet.

Parameters:

options - the serializable options for this subscription

subset - if provided, is a position-space filter of source data

Returns:

a single-use DrainableColumn ready to be drained via grpc

Throws:

IOException