Package io.deephaven.extensions.barrage.chunk

Class VarBinaryChunkInputStreamGenerator<T>

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator<ObjectChunk<T,Values>>

io.deephaven.extensions.barrage.chunk.VarBinaryChunkInputStreamGenerator<T>

All Implemented Interfaces:

LogOutputAppendable, 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.BufferListener, ChunkInputStreamGenerator.DrainableColumn, ChunkInputStreamGenerator.Factory, ChunkInputStreamGenerator.FieldNodeInfo, ChunkInputStreamGenerator.FieldNodeListener

Field Summary

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

chunk, elementSize, PADDING_BUFFER, REMAINDER_MOD_8_MASK

Fields inherited from interface io.deephaven.extensions.barrage.chunk.ChunkInputStreamGenerator

MAX_LOCAL_DATE_VALUE, MIN_LOCAL_DATE_VALUE, MS_PER_DAY

Method Summary

Modifier and Type	Method	Description
static <T> WritableObjectChunk<T,Values>	extractChunkFromInputStream(DataInput is, Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, VarBinaryChunkInputStreamGenerator.Mapper<T> mapper, WritableChunk<Values> outChunk, int outOffset, int totalRows)
ChunkInputStreamGenerator.DrainableColumn	getInputStream(StreamReaderOptions options, @Nullable RowSet subset)	Get an input stream optionally position-space filtered using the provided RowSet.
protected void	onReferenceCountAtZero()	Callback method that will be invoked when the reference count returns to zero.

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

close, getLastRowOffset, getNumLongsForBitPackOfSize, getRowOffset, getValidityMapSerializationSizeFor

Methods inherited from class io.deephaven.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

Method Details

onReferenceCountAtZero

protected void onReferenceCountAtZero()

Description copied from class: ReferenceCounted

Callback method that will be invoked when the reference count returns to zero.

Overrides:

onReferenceCountAtZero 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

extractChunkFromInputStream

public static <T> WritableObjectChunk<T,Values> extractChunkFromInputStream(DataInput is,
 Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter,
 PrimitiveIterator.OfLong bufferInfoIter,
 VarBinaryChunkInputStreamGenerator.Mapper<T> mapper,
 WritableChunk<Values> outChunk,
 int outOffset,
 int totalRows)
                                                                     throws IOException

Throws:

IOException