Package io.deephaven.extensions.barrage.chunk

Class LongChunkInputStreamGenerator

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

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

io.deephaven.extensions.barrage.chunk.LongChunkInputStreamGenerator

All Implemented Interfaces:

LogOutputAppendable, ChunkInputStreamGenerator, SafeCloseable, AutoCloseable

public class LongChunkInputStreamGenerator
extends BaseChunkInputStreamGenerator<LongChunk<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 LongChunkInputStreamGenerator	convertBoxed(ObjectChunk<Long,Values> inChunk, long rowOffset)
static <T> LongChunkInputStreamGenerator	convertWithTransform(ObjectChunk<T,Values> inChunk, long rowOffset, ToLongFunction<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 LongChunkInputStreamGenerator convertBoxed(ObjectChunk<Long,Values> inChunk,
 long rowOffset)

convertWithTransform

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