Package io.deephaven.extensions.barrage.chunk

Class BaseChunkReader<READ_CHUNK_TYPE extends WritableChunk<Values>>

java.lang.Object

io.deephaven.extensions.barrage.chunk.BaseChunkReader<READ_CHUNK_TYPE>

All Implemented Interfaces:

ChunkReader<READ_CHUNK_TYPE>

Direct Known Subclasses:

BooleanChunkReader, ByteChunkReader, CharChunkReader, DictionaryChunkReader, DoubleChunkReader, FixedWidthChunkReader, FloatChunkReader, IntChunkReader, ListChunkReader, LongChunkReader, MapChunkReader, NullChunkReader, RunEndEncodedChunkReader, ShortChunkReader, SingleElementListHeaderReader, TransformingChunkReader, UnionChunkReader, VarBinaryChunkReader

public abstract class BaseChunkReader<READ_CHUNK_TYPE extends WritableChunk<Values>>
extends Object
implements ChunkReader<READ_CHUNK_TYPE>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BaseChunkReader.ChunkTransformer<READ_CHUNK_TYPE extends Chunk<Values>,DEST_CHUNK_TYPE extends WritableChunk<Values>>

Nested classes/interfaces inherited from interface io.deephaven.extensions.barrage.chunk.ChunkReader

ChunkReader.Factory

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	BULK_READ_BUFFER_BYTES	Upper bound (in bytes) on a single bulk payload read shared by the fixed-width primitive readers.

Constructor Summary

Constructors

Constructor	Description
BaseChunkReader()

Method Summary

Modifier and Type	Method	Description
static <ATTR extends Any, T extends WritableChunk<ATTR>> T	castOrCreateChunk(WritableChunk<ATTR> outChunk, int outOffset, int numRows, IntFunction<T> chunkFactory, Function<WritableChunk<ATTR>,T> castFunction)
static ChunkType	getChunkTypeFor(Class<?> dest)
protected static void	readValidityBuffer(@NotNull DataInput is, int numValidityLongs, long validityBufferLength, @NotNull WritableLongChunk<Values> isValid, @NotNull String DEBUG_NAME)

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

readChunk, readChunk

Field Details

BULK_READ_BUFFER_BYTES

protected static final int BULK_READ_BUFFER_BYTES

Upper bound (in bytes) on a single bulk payload read shared by the fixed-width primitive readers. Wide columns are decoded in windows of this size rather than materializing the entire payload at once. Configure once here (rather than per type) via BaseChunkReader.bulkReadBufferBytes.

Constructor Details

BaseChunkReader

public BaseChunkReader()

Method Details

castOrCreateChunk

public static <ATTR extends Any,
T extends WritableChunk<ATTR>>
T castOrCreateChunk(WritableChunk<ATTR> outChunk,
 int outOffset,
 int numRows,
 IntFunction<T> chunkFactory,
 Function<WritableChunk<ATTR>,T> castFunction)

getChunkTypeFor

public static ChunkType getChunkTypeFor(Class<?> dest)

readValidityBuffer

protected static void readValidityBuffer(@NotNull
 @NotNull DataInput is,
 int numValidityLongs,
 long validityBufferLength,
 @NotNull
 @NotNull WritableLongChunk<Values> isValid,
 @NotNull
 @NotNull String DEBUG_NAME)
                                  throws IOException

Throws:

IOException