Package io.deephaven.barrage.chunk

Class VectorChunkInputStreamGenerator

java.lang.Object

io.deephaven.barrage.chunk.BaseChunkInputStreamGenerator<ObjectChunk<DbArrayBase,Attributes.Values>>

io.deephaven.barrage.chunk.VectorChunkInputStreamGenerator

All Implemented Interfaces:

SafeCloseable, ChunkInputStreamGenerator, AutoCloseable

public class VectorChunkInputStreamGenerator
extends BaseChunkInputStreamGenerator<ObjectChunk<DbArrayBase,Attributes.Values>>

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.barrage.chunk.BaseChunkInputStreamGenerator

BaseChunkInputStreamGenerator.SerContext

Nested classes/interfaces inherited from interface io.deephaven.barrage.chunk.ChunkInputStreamGenerator

ChunkInputStreamGenerator.BufferListener, ChunkInputStreamGenerator.DrainableColumn, ChunkInputStreamGenerator.FieldNodeInfo, ChunkInputStreamGenerator.FieldNodeListener

Field Summary

Fields inherited from class io.deephaven.barrage.chunk.BaseChunkInputStreamGenerator

chunk, elementSize, PADDING_BUFFER, REFERENCE_COUNT_UPDATER, REMAINDER_MOD_8_MASK

Method Summary

Modifier and Type	Method	Description
void	close()
ChunkInputStreamGenerator.DrainableColumn	getInputStream(StreamReaderOptions options, @Nullable Index subset)	Get an input stream optionally position-space filtered using the provided RowSet.

Methods inherited from class io.deephaven.barrage.chunk.BaseChunkInputStreamGenerator

getLastRowOffset, getNumLongsForBitPackOfSize, getRowOffset, getValidityMapSerializationSizeFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

Overrides:

close in class BaseChunkInputStreamGenerator<ObjectChunk<DbArrayBase,Attributes.Values>>

getInputStream

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

Description copied from interface: ChunkInputStreamGenerator

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