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 final class	ChunkInputStreamGenerator.BufferInfo
static interface	ChunkInputStreamGenerator.BufferListener
static class	ChunkInputStreamGenerator.DrainableColumn
static final class	ChunkInputStreamGenerator.FieldNodeInfo
static interface	ChunkInputStreamGenerator.FieldNodeListener

Method Summary

Modifier and Type	Method	Description
static WritableChunk<Values>	extractChunkFromInputStream(StreamReaderOptions options, int factor, ChunkType chunkType, Class<?> type, Class<?> componentType, Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, DataInput is, WritableChunk<Values> outChunk, int outOffset, int totalRows)
static WritableChunk<Values>	extractChunkFromInputStream(StreamReaderOptions options, ChunkType chunkType, Class<?> type, Class<?> componentType, Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, DataInput is, WritableChunk<Values> outChunk, int offset, int totalRows)
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.
static <T> ChunkInputStreamGenerator	makeInputStreamGenerator(ChunkType chunkType, Class<T> type, Class<?> componentType, Chunk<Values> chunk, long rowOffset)

Methods inherited from interface io.deephaven.util.SafeCloseable

close

Method Details

makeInputStreamGenerator

static <T> ChunkInputStreamGenerator makeInputStreamGenerator(ChunkType chunkType,
 Class<T> type,
 Class<?> componentType,
 Chunk<Values> chunk,
 long rowOffset)

extractChunkFromInputStream

static WritableChunk<Values> extractChunkFromInputStream(StreamReaderOptions options,
 ChunkType chunkType,
 Class<?> type,
 Class<?> componentType,
 Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter,
 PrimitiveIterator.OfLong bufferInfoIter,
 DataInput is,
 WritableChunk<Values> outChunk,
 int offset,
 int totalRows)
                                                  throws IOException

Throws:

IOException

extractChunkFromInputStream

static WritableChunk<Values> extractChunkFromInputStream(StreamReaderOptions options,
 int factor,
 ChunkType chunkType,
 Class<?> type,
 Class<?> componentType,
 Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter,
 PrimitiveIterator.OfLong bufferInfoIter,
 DataInput is,
 WritableChunk<Values> outChunk,
 int outOffset,
 int totalRows)
                                                  throws IOException

Throws:

IOException

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