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.ChunkTransformer<SOURCE_CHUNK_TYPE extends Chunk<Values>>, BaseChunkWriter.SerContext

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

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 int	computeNullCount(@NotNull ChunkWriter.Context context, @NotNull RowSequence subset)	Compute the number of nulls in the subset.
protected void	writePayload(@NotNull ChunkWriter.Context context, @NotNull DataOutput dos, @NotNull RowSequence subset)
protected void	writeValidityBufferInternal(@NotNull ChunkWriter.Context context, @NotNull RowSequence subset, @NotNull BaseChunkWriter.SerContext serContext)	Update the validity buffer for the subset.

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

getInputStream

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

getEmptyInputStream, getNumLongsForBitPackOfSize, getValidityMapSerializationSizeFor, isFieldNullable, makeContext

Methods inherited from class java.lang.Object

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

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

computeNullCount

protected int computeNullCount(@NotNull
 @NotNull ChunkWriter.Context context,
 @NotNull
 @NotNull RowSequence subset)

Description copied from class: BaseChunkWriter

Compute the number of nulls in the subset.

Specified by:

computeNullCount in class BaseChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

Returns:

the number of nulls in the subset

writeValidityBufferInternal

protected void writeValidityBufferInternal(@NotNull
 @NotNull ChunkWriter.Context context,
 @NotNull
 @NotNull RowSequence subset,
 @NotNull
 @NotNull BaseChunkWriter.SerContext serContext)

Description copied from class: BaseChunkWriter

Update the validity buffer for the subset.

Specified by:

writeValidityBufferInternal in class BaseChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

serContext - the serialization context

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>>