Package io.deephaven.extensions.barrage.chunk

Class BooleanChunkReader

java.lang.Object

io.deephaven.extensions.barrage.chunk.BooleanChunkReader

All Implemented Interfaces:

ChunkReader

public class BooleanChunkReader
extends Object
implements ChunkReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BooleanChunkReader.ByteConversion

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

ChunkReader.Factory, ChunkReader.TypeInfo

Constructor Summary

Constructors

Constructor	Description
BooleanChunkReader()
BooleanChunkReader(BooleanChunkReader.ByteConversion conversion)

Method Summary

Modifier and Type	Method	Description
WritableChunk<Values>	readChunk(Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, DataInput is, WritableChunk<Values> outChunk, int outOffset, int totalRows)	Reads the given DataInput to extract the next Arrow buffer as a Deephaven Chunk.

Methods inherited from class java.lang.Object

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

Constructor Details

BooleanChunkReader

public BooleanChunkReader()

BooleanChunkReader

public BooleanChunkReader(BooleanChunkReader.ByteConversion conversion)

Method Details

readChunk

public WritableChunk<Values> readChunk(Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter,
 PrimitiveIterator.OfLong bufferInfoIter,
 DataInput is,
 WritableChunk<Values> outChunk,
 int outOffset,
 int totalRows)
                                throws IOException

Description copied from interface: ChunkReader

Reads the given DataInput to extract the next Arrow buffer as a Deephaven Chunk.

Specified by:

readChunk in interface ChunkReader

Parameters:

fieldNodeIter - iterator to read fields from the stream

bufferInfoIter - iterator to read buffers from the stream

is - input stream containing buffers to be read

outChunk - chunk to write to

outOffset - offset within the outChunk to begin writing

totalRows - total rows to write to the outChunk

Returns:

a Chunk containing the data from the stream

Throws:

IOException - if an error occurred while reading the stream