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, DoubleChunkReader, FixedWidthChunkReader, FloatChunkReader, IntChunkReader, ListChunkReader, LongChunkReader, MapChunkReader, NullChunkReader, ShortChunkReader, SingleElementListHeaderReader, TransformingChunkReader, UnionChunkReader

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

Constructor Summary

Constructors

Constructor	Description
BaseChunkReader()

Method Summary

Modifier and Type	Method	Description
protected static <T extends WritableChunk<Values>> T	castOrCreateChunk(WritableChunk<Values> outChunk, int numRows, IntFunction<T> chunkFactory, Function<WritableChunk<Values>,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

Constructor Details

BaseChunkReader

public BaseChunkReader()

Method Details

castOrCreateChunk

protected static <T extends WritableChunk<Values>>
T castOrCreateChunk(WritableChunk<Values> outChunk,
 int numRows,
 IntFunction<T> chunkFactory,
 Function<WritableChunk<Values>,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