Package io.deephaven.extensions.barrage.chunk

Class BooleanChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>

java.lang.Object

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

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

All Implemented Interfaces:

ChunkWriter<SOURCE_CHUNK_TYPE>

public class BooleanChunkWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>
extends BaseChunkWriter<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
BooleanChunkWriter(@Nullable BaseChunkWriter.ChunkTransformer<SOURCE_CHUNK_TYPE> transformer, @NotNull Supplier<SOURCE_CHUNK_TYPE> emptyChunkSupplier, 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.
static BooleanChunkWriter<ByteChunk<Values>>	getIdentity(boolean isNullable)
ChunkWriter.DrainableColumn	getInputStream(@NotNull ChunkWriter.Context context, @Nullable RowSet subset, @NotNull BarrageOptions options)	Get an input stream optionally position-space filtered using the provided RowSet.

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

BooleanChunkWriter

public BooleanChunkWriter(@Nullable
 @Nullable BaseChunkWriter.ChunkTransformer<SOURCE_CHUNK_TYPE> transformer,
 @NotNull
 @NotNull Supplier<SOURCE_CHUNK_TYPE> emptyChunkSupplier,
 boolean fieldNullable)

Method Details

getIdentity

public static BooleanChunkWriter<ByteChunk<Values>> getIdentity(boolean isNullable)

getInputStream

public ChunkWriter.DrainableColumn getInputStream(@NotNull
 @NotNull ChunkWriter.Context context,
 @Nullable
 @Nullable RowSet subset,
 @NotNull
 @NotNull BarrageOptions options)
                                           throws IOException

Description copied from interface: ChunkWriter

Get an input stream optionally position-space filtered using the provided RowSet.

Parameters:

context - the chunk writer context holding the data to be drained to the client

subset - if provided, is a position-space filter of source data

options - options for writing to the stream

Returns:

a single-use DrainableColumn ready to be drained via grpc

Throws:

IOException

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