Package io.deephaven.extensions.barrage.chunk

Class NullChunkWriter

java.lang.Object

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

io.deephaven.extensions.barrage.chunk.NullChunkWriter

All Implemented Interfaces:

ChunkWriter<Chunk<Values>>

public class NullChunkWriter
extends BaseChunkWriter<Chunk<Values>>

A ChunkWriter implementation that writes an Apache Arrow Null Column; which only writes a field node.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NullChunkWriter.NullDrainableColumn

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

Modifier and Type	Field	Description
static final NullChunkWriter	INSTANCE

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

dhNullable, elementSize, fieldNullable, PADDING_BUFFER, REMAINDER_MOD_8_MASK

Constructor Summary

Constructors

Constructor	Description
NullChunkWriter()

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.
ChunkWriter.DrainableColumn	getInputStream(@NotNull ChunkWriter.Context chunk, @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

Field Details

INSTANCE

public static final NullChunkWriter INSTANCE

Constructor Details

NullChunkWriter

public NullChunkWriter()

Method Details

getInputStream

public ChunkWriter.DrainableColumn getInputStream(@NotNull
 @NotNull ChunkWriter.Context chunk,
 @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:

chunk - 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<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<Chunk<Values>>

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

serContext - the serialization context