Package io.deephaven.extensions.barrage.chunk

Class FixedWidthObjectChunkWriter<T>

java.lang.Object

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

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

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

All Implemented Interfaces:

ChunkWriter<ObjectChunk<T,Values>>

public abstract class FixedWidthObjectChunkWriter<T>
extends FixedWidthChunkWriter<ObjectChunk<T,Values>>

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.extensions.barrage.chunk.BaseChunkWriter

BaseChunkWriter.BulkIntWriter, BaseChunkWriter.ChunkTransformer<SOURCE_CHUNK_TYPE extends Chunk<Values>>, BaseChunkWriter.ValidityBuffer

Nested classes/interfaces inherited from interface io.deephaven.extensions.barrage.chunk.ChunkWriter

ChunkWriter.BufferListener, ChunkWriter.Context, ChunkWriter.DrainableColumn, ChunkWriter.Factory, ChunkWriter.FieldNodeInfo, ChunkWriter.FieldNodeListener

Field Summary

Fields inherited from class io.deephaven.extensions.barrage.chunk.BaseChunkWriter

BULK_WRITE_BUFFER_BYTES, dhNullable, elementSize, fieldNullable, PADDING_BUFFER, REMAINDER_MOD_8_MASK

Constructor Summary

Constructors

Constructor	Description
FixedWidthObjectChunkWriter(int elementSize, boolean dhNullable, boolean fieldNullable)

Method Summary

Modifier and Type	Method	Description
protected void	computeValidity(ChunkWriter.Context context, @NotNull RowSequence subset, @NotNull BaseChunkWriter.ValidityBuffer validity)	Report the nullness of each row of the subset, in order, to validity.

Methods inherited from class io.deephaven.extensions.barrage.chunk.FixedWidthChunkWriter

getInputStream, writePayload

Methods inherited from class io.deephaven.extensions.barrage.chunk.BaseChunkWriter

getEmptyInputStream, getEmptyInputStream, getNumLongsForBitPackOfSize, getValidityMapSerializationSizeFor, isFieldNullable, makeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.extensions.barrage.chunk.ChunkWriter

getInputStream

Constructor Details

FixedWidthObjectChunkWriter

public FixedWidthObjectChunkWriter(int elementSize,
 boolean dhNullable,
 boolean fieldNullable)

Method Details

computeValidity

protected void computeValidity(@NotNull
 ChunkWriter.Context context,
 @NotNull
 @NotNull RowSequence subset,
 @NotNull
 @NotNull BaseChunkWriter.ValidityBuffer validity)

Description copied from class: BaseChunkWriter

Report the nullness of each row of the subset, in order, to validity.

This is invoked at most once per BaseChunkWriter.BaseChunkInputStream: the null count carried by the field node and the bytes of the validity buffer are both derived from this single traversal of the row data.

Specified by:

computeValidity in class BaseChunkWriter<ObjectChunk<T,Values>>

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

validity - the validity buffer to populate