Package io.deephaven.extensions.barrage.chunk

Class FixedWidthChunkInputStreamGenerator

java.lang.Object

io.deephaven.extensions.barrage.chunk.FixedWidthChunkInputStreamGenerator

public class FixedWidthChunkInputStreamGenerator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FixedWidthChunkInputStreamGenerator.TypeConversion<T>

Constructor Summary

Constructors

Constructor	Description
FixedWidthChunkInputStreamGenerator()

Method Summary

Modifier and Type	Method	Description
static <T> WritableObjectChunk<T,Values>	extractChunkFromInputStreamWithTypeConversion(int elementSize, StreamReaderOptions options, FixedWidthChunkInputStreamGenerator.TypeConversion<T> conversion, Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, DataInput is, WritableChunk<Values> outChunk, int outOffset, int totalRows)	Generic input stream reading from arrow's buffer and convert directly to java type.

Methods inherited from class java.lang.Object

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

Constructor Details

FixedWidthChunkInputStreamGenerator

public FixedWidthChunkInputStreamGenerator()

Method Details

extractChunkFromInputStreamWithTypeConversion

public static <T> WritableObjectChunk<T,Values> extractChunkFromInputStreamWithTypeConversion(int elementSize,
 StreamReaderOptions options,
 FixedWidthChunkInputStreamGenerator.TypeConversion<T> conversion,
 Iterator<ChunkInputStreamGenerator.FieldNodeInfo> fieldNodeIter,
 PrimitiveIterator.OfLong bufferInfoIter,
 DataInput is,
 WritableChunk<Values> outChunk,
 int outOffset,
 int totalRows)
                                                                                       throws IOException

Generic input stream reading from arrow's buffer and convert directly to java type. If useDeephavenNulls is enabled, then the conversion method must properly return a null value.

Type Parameters:

T - the result type

Parameters:

elementSize - the number of bytes per element (element size is fixed)

options - the stream reader options

conversion - the conversion method from input stream to the result type

fieldNodeIter - arrow field node iterator

bufferInfoIter - arrow buffer info iterator

outChunk - the returned chunk from an earlier record batch

outOffset - the offset to start writing into outChunk

totalRows - the total known rows for this column; if known (else 0)

is - data input stream

Returns:

the resulting chunk of the buffer that is read

Throws:

IOException