Package io.deephaven.extensions.barrage.chunk

Class ListChunkWriter<LIST_TYPE,COMPONENT_CHUNK_TYPE extends Chunk<Values>>

java.lang.Object

io.deephaven.extensions.barrage.chunk.BaseChunkWriter<ObjectChunk<LIST_TYPE,Values>>

io.deephaven.extensions.barrage.chunk.ListChunkWriter<LIST_TYPE,COMPONENT_CHUNK_TYPE>

All Implemented Interfaces:

ChunkWriter<ObjectChunk<LIST_TYPE,Values>>

public class ListChunkWriter<LIST_TYPE,COMPONENT_CHUNK_TYPE extends Chunk<Values>>
extends BaseChunkWriter<ObjectChunk<LIST_TYPE,Values>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	ListChunkWriter.Context

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.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
ListChunkWriter(ListChunkReader.Mode mode, int fixedSizeLength, ExpansionKernel<LIST_TYPE> kernel, ChunkWriter<COMPONENT_CHUNK_TYPE> componentWriter, boolean fieldNullable)

Method Summary

Modifier and Type	Method	Description
protected int	computeNullCount(ChunkWriter.Context context, @NotNull RowSequence subset)	Compute the number of nulls in the subset.
ChunkWriter.DrainableColumn	getInputStream(ChunkWriter.Context context, @Nullable RowSet subset, @NotNull BarrageOptions options)	Get an input stream optionally position-space filtered using the provided RowSet.
ListChunkWriter<LIST_TYPE,COMPONENT_CHUNK_TYPE>.Context	makeContext(@NotNull ObjectChunk<LIST_TYPE,Values> chunk, long rowOffset)	Create a context for the given chunk.
protected void	writeValidityBufferInternal(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

Methods inherited from class java.lang.Object

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

Constructor Details

ListChunkWriter

public ListChunkWriter(ListChunkReader.Mode mode,
 int fixedSizeLength,
 ExpansionKernel<LIST_TYPE> kernel,
 ChunkWriter<COMPONENT_CHUNK_TYPE> componentWriter,
 boolean fieldNullable)

Method Details

computeNullCount

protected int computeNullCount(@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<ObjectChunk<LIST_TYPE,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
 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<ObjectChunk<LIST_TYPE,Values>>

Parameters:

context - the context for the chunk

subset - the subset of rows to consider

serContext - the serialization context

makeContext

public ListChunkWriter<LIST_TYPE,COMPONENT_CHUNK_TYPE>.Context makeContext(@NotNull
 @NotNull ObjectChunk<LIST_TYPE,Values> chunk,
 long rowOffset)

Description copied from interface: ChunkWriter

Create a context for the given chunk.

Specified by:

makeContext in interface ChunkWriter<LIST_TYPE>

Overrides:

makeContext in class BaseChunkWriter<ObjectChunk<LIST_TYPE,Values>>

Parameters:

chunk - the chunk of data to be written

rowOffset - the offset into the logical message potentially spread over multiple chunks

Returns:

a context for the given chunk

getInputStream

public ChunkWriter.DrainableColumn getInputStream(@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