Package io.deephaven.extensions.barrage.chunk

Class ByteChunkInputStreamGenerator

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

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

io.deephaven.extensions.barrage.chunk.ByteChunkInputStreamGenerator

All Implemented Interfaces:

LogOutputAppendable, ChunkInputStreamGenerator, SafeCloseable, AutoCloseable

public class ByteChunkInputStreamGenerator
extends BaseChunkInputStreamGenerator<ByteChunk<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 ByteChunkInputStreamGenerator	convertBoxed(ObjectChunk<Byte,Values> inChunk, long rowOffset)
static <T> ByteChunkInputStreamGenerator	convertWithTransform(ObjectChunk<T,Values> inChunk, long rowOffset, ToByteFunction<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 ByteChunkInputStreamGenerator convertBoxed(ObjectChunk<Byte,Values> inChunk,
 long rowOffset)

convertWithTransform

public static <T> ByteChunkInputStreamGenerator convertWithTransform(ObjectChunk<T,Values> inChunk,
 long rowOffset,
 ToByteFunction<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