Package io.deephaven.extensions.barrage.chunk

Class DoubleChunkReader

java.lang.Object

io.deephaven.extensions.barrage.chunk.DoubleChunkReader

All Implemented Interfaces:

ChunkReader

public class DoubleChunkReader
extends Object
implements ChunkReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DoubleChunkReader.DoubleConversion

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

ChunkReader.Factory, ChunkReader.TypeInfo

Constructor Summary

Constructors

Constructor	Description
DoubleChunkReader(StreamReaderOptions options)
DoubleChunkReader(StreamReaderOptions options, DoubleChunkReader.DoubleConversion conversion)

Method Summary

Modifier and Type	Method	Description
WritableDoubleChunk<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.
<T> ChunkReader	transform(Function<Double,T> transform)

Methods inherited from class java.lang.Object

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

Constructor Details

DoubleChunkReader

public DoubleChunkReader(StreamReaderOptions options)

DoubleChunkReader

public DoubleChunkReader(StreamReaderOptions options,
 DoubleChunkReader.DoubleConversion conversion)

Method Details

transform

public <T> ChunkReader transform(Function<Double,T> transform)

readChunk

public WritableDoubleChunk<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