Package io.deephaven.extensions.barrage.chunk

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

Nested Classes

Modifier and Type	Class	Description
static interface	VarBinaryChunkInputStreamGenerator.Appender<T>
static class	VarBinaryChunkInputStreamGenerator.ByteStorage
static interface	VarBinaryChunkInputStreamGenerator.Mapper<T>

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 Type	Method	Description
void	close()
ChunkInputStreamGenerator.DrainableColumn	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

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<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 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