Class VarBinaryChunkInputStreamGenerator<T>
java.lang.Object
io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator<ObjectChunk<T,Values>>
io.deephaven.extensions.barrage.chunk.VarBinaryChunkInputStreamGenerator<T>
- All Implemented Interfaces:
ChunkInputStreamGenerator
,SafeCloseable
,AutoCloseable
public class VarBinaryChunkInputStreamGenerator<T>
extends BaseChunkInputStreamGenerator<ObjectChunk<T,Values>>
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic interface
static class
static interface
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 TypeMethodDescriptionvoid
close()
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
getLastRowOffset, getNumLongsForBitPackOfSize, getRowOffset, getValidityMapSerializationSizeFor
-
Method Details
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceSafeCloseable
- Overrides:
close
in classBaseChunkInputStreamGenerator<ObjectChunk<T,
Values>>
-
getInputStream
public ChunkInputStreamGenerator.DrainableColumn getInputStream(StreamReaderOptions options, @Nullable @Nullable RowSet 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 subscriptionsubset
- if provided, is a position-space filter of source data- Returns:
- a single-use DrainableColumn ready to be drained via grpc
- Throws:
IOException
-