Package io.deephaven.extensions.barrage.chunk

Class BigDecimalChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>

java.lang.Object

io.deephaven.extensions.barrage.chunk.BaseChunkWriter<SOURCE_CHUNK_TYPE>

io.deephaven.extensions.barrage.chunk.FixedWidthChunkWriter<SOURCE_CHUNK_TYPE>

io.deephaven.extensions.barrage.chunk.BigDecimalChunkWriter<SOURCE_CHUNK_TYPE>

All Implemented Interfaces:

ChunkWriter<SOURCE_CHUNK_TYPE>

public class BigDecimalChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>
extends FixedWidthChunkWriter<SOURCE_CHUNK_TYPE>

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
BigDecimalChunkWriter(@Nullable BaseChunkWriter.ChunkTransformer<SOURCE_CHUNK_TYPE> transformer, org.apache.arrow.vector.types.pojo.ArrowType.Decimal decimalType, @NotNull Supplier<SOURCE_CHUNK_TYPE> emptyChunkSupplier, int elementSize, boolean dhNullable, boolean fieldNullable)

Method Summary

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

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

getInputStream

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

BigDecimalChunkWriter

public BigDecimalChunkWriter(@Nullable
 @Nullable BaseChunkWriter.ChunkTransformer<SOURCE_CHUNK_TYPE> transformer,
 org.apache.arrow.vector.types.pojo.ArrowType.Decimal decimalType,
 @NotNull
 @NotNull Supplier<SOURCE_CHUNK_TYPE> emptyChunkSupplier,
 int elementSize,
 boolean dhNullable,
 boolean fieldNullable)

Method Details

computeValidity

protected void computeValidity(@NotNull
 @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<SOURCE_CHUNK_TYPE extends Chunk<Values>>

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

validity - the validity buffer to populate

writePayload

protected void writePayload(@NotNull
 @NotNull ChunkWriter.Context context,
 @NotNull
 @NotNull DataOutput dos,
 @NotNull
 @NotNull RowSequence subset)

Specified by:

writePayload in class FixedWidthChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>