Package io.deephaven.extensions.barrage.chunk

Class BooleanChunkWriter

java.lang.Object

io.deephaven.extensions.barrage.chunk.BaseChunkWriter<ByteChunk<Values>>

io.deephaven.extensions.barrage.chunk.BooleanChunkWriter

All Implemented Interfaces:

ChunkWriter<ByteChunk<Values>>

public class BooleanChunkWriter
extends BaseChunkWriter<ByteChunk<Values>>

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

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.
static BooleanChunkWriter	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.
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.BaseChunkWriter

getEmptyInputStream, getNumLongsForBitPackOfSize, getValidityMapSerializationSizeFor, isFieldNullable, makeContext

Methods inherited from class java.lang.Object

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

Method Details

getIdentity

public static BooleanChunkWriter 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

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

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

serContext - the serialization context