Package io.deephaven.extensions.barrage.chunk

Class LongChunkInputStreamGenerator

java.lang.Object

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

io.deephaven.extensions.barrage.chunk.LongChunkInputStreamGenerator

All Implemented Interfaces:

ChunkInputStreamGenerator, SafeCloseable, AutoCloseable

public class LongChunkInputStreamGenerator
extends BaseChunkInputStreamGenerator<LongChunk<Values>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LongChunkInputStreamGenerator.LongConversion

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
static LongChunkInputStreamGenerator	convertBoxed(ObjectChunk<Long,Values> inChunk, long rowOffset)
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

Methods inherited from class java.lang.Object

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

Method Details

convertBoxed

public static LongChunkInputStreamGenerator convertBoxed(ObjectChunk<Long,Values> inChunk,
 long rowOffset)

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