Package io.deephaven.extensions.barrage.chunk

Class VarBinaryChunkReader<T>

java.lang.Object

io.deephaven.extensions.barrage.chunk.VarBinaryChunkReader<T>

All Implemented Interfaces:

ChunkReader<WritableObjectChunk<T,Values>>

public class VarBinaryChunkReader<T>
extends Object
implements ChunkReader<WritableObjectChunk<T,Values>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	VarBinaryChunkReader.Mapper<T>

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

ChunkReader.Factory

Constructor Summary

Constructors

Constructor	Description
VarBinaryChunkReader(VarBinaryChunkReader.Mapper<T> mapper)

Method Summary

Modifier and Type	Method	Description
WritableObjectChunk<T,Values>	readChunk(@NotNull Iterator<ChunkWriter.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, @NotNull DataInput is, @Nullable 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

Methods inherited from interface io.deephaven.extensions.barrage.chunk.ChunkReader

readChunk

Constructor Details

VarBinaryChunkReader

public VarBinaryChunkReader(VarBinaryChunkReader.Mapper<T> mapper)

Method Details

readChunk

public WritableObjectChunk<T,Values> readChunk(@NotNull
 @NotNull Iterator<ChunkWriter.FieldNodeInfo> fieldNodeIter,
 @NotNull
 PrimitiveIterator.OfLong bufferInfoIter,
 @NotNull
 @NotNull DataInput is,
 @Nullable
 @Nullable 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<T>

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