Package io.deephaven.extensions.barrage.chunk

Class ShortChunkInputStreamGenerator

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator<ShortChunk<Values>>

io.deephaven.extensions.barrage.chunk.ShortChunkInputStreamGenerator

All Implemented Interfaces:

LogOutputAppendable, 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.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 ShortChunkInputStreamGenerator	convertBoxed(ObjectChunk<Short,Values> inChunk, long rowOffset)
static <T> ShortChunkInputStreamGenerator	convertWithTransform(ObjectChunk<T,Values> inChunk, long rowOffset, ToShortFunction<T> transform)
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

close, getLastRowOffset, getNumLongsForBitPackOfSize, getRowOffset, getValidityMapSerializationSizeFor, onReferenceCountAtZero

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

convertBoxed

public static ShortChunkInputStreamGenerator convertBoxed(ObjectChunk<Short,Values> inChunk,
 long rowOffset)

convertWithTransform

public static <T> ShortChunkInputStreamGenerator convertWithTransform(ObjectChunk<T,Values> inChunk,
 long rowOffset,
 ToShortFunction<T> transform)

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 subscription

subset - if provided, is a position-space filter of source data

Returns:

a single-use DrainableColumn ready to be drained via grpc