Package io.deephaven.extensions.barrage.chunk

Class VarListChunkInputStreamGenerator<T>

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

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

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

All Implemented Interfaces:

LogOutputAppendable, ChunkInputStreamGenerator, SafeCloseable, AutoCloseable

public class VarListChunkInputStreamGenerator<T>
extends BaseChunkInputStreamGenerator<ObjectChunk<T,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.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
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