Class ShortChunkInputStreamGenerator
java.lang.Object
io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator<ShortChunk<Values>>
io.deephaven.extensions.barrage.chunk.ShortChunkInputStreamGenerator
- All Implemented Interfaces:
ChunkInputStreamGenerator
,SafeCloseable
,AutoCloseable
public class ShortChunkInputStreamGenerator
extends BaseChunkInputStreamGenerator<ShortChunk<Values>>
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator
BaseChunkInputStreamGenerator.SerContext
Nested classes/interfaces inherited from interface io.deephaven.extensions.barrage.chunk.ChunkInputStreamGenerator
ChunkInputStreamGenerator.BufferInfo, ChunkInputStreamGenerator.BufferListener, ChunkInputStreamGenerator.DrainableColumn, ChunkInputStreamGenerator.FieldNodeInfo, ChunkInputStreamGenerator.FieldNodeListener
-
Field Summary
Fields inherited from class io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator
chunk, elementSize, PADDING_BUFFER, REFERENCE_COUNT_UPDATER, REMAINDER_MOD_8_MASK
-
Method Summary
Modifier and TypeMethodDescriptionconvertBoxed
(ObjectChunk<Short, Values> inChunk, long rowOffset) getInputStream
(StreamReaderOptions options, @Nullable RowSet subset) Get an input stream optionally position-space filtered using the provided RowSet.Methods inherited from class io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator
close, getLastRowOffset, getNumLongsForBitPackOfSize, getRowOffset, getValidityMapSerializationSizeFor
-
Method Details
-
convertBoxed
public static ShortChunkInputStreamGenerator convertBoxed(ObjectChunk<Short, Values> inChunk, long rowOffset) -
getInputStream
public ChunkInputStreamGenerator.DrainableColumn getInputStream(StreamReaderOptions options, @Nullable @Nullable RowSet subset) Description copied from interface:ChunkInputStreamGenerator
Get an input stream optionally position-space filtered using the provided RowSet.- Parameters:
options
- the serializable options for this subscriptionsubset
- if provided, is a position-space filter of source data- Returns:
- a single-use DrainableColumn ready to be drained via grpc
-