Package io.deephaven.web.client.api.barrage

Class WebChunkReaderFactory

java.lang.Object

io.deephaven.web.client.api.barrage.WebChunkReaderFactory

All Implemented Interfaces:

ChunkReader.Factory

public class WebChunkReaderFactory
extends Object
implements ChunkReader.Factory

Browser-compatible implementation of the ChunkReader.Factory, with a focus on reading from arrow types rather than successfully round-tripping to the Java server.

Includes some specific workarounds to handle nullability that will make more sense for the browser.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
WebChunkReaderFactory()

Method Summary

Modifier and Type	Method	Description
static <T> WritableObjectChunk<T,Values>	extractChunkFromInputStream(DataInput is, Iterator<ChunkWriter.FieldNodeInfo> fieldNodeIter, PrimitiveIterator.OfLong bufferInfoIter, WebChunkReaderFactory.Mapper<T> mapper, WritableChunk<Values> outChunk, int outOffset, int totalRows)
<T extends WritableChunk<Values>> ChunkReader<T>	newReader(@NotNull BarrageTypeInfo<org.apache.arrow.flatbuf.Field> typeInfo, @NotNull BarrageOptions options)	Returns a ChunkReader for the specified arguments.
static <T, WIRE_CHUNK_TYPE extends WritableChunk<Values>, CR extends ChunkReader<WIRE_CHUNK_TYPE>> ChunkReader<WritableObjectChunk<T,Values>>	transformToObject(CR wireReader, BaseChunkReader.ChunkTransformer<WIRE_CHUNK_TYPE,WritableObjectChunk<T,Values>> wireTransform)

Methods inherited from class java.lang.Object

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

Constructor Details

WebChunkReaderFactory

public WebChunkReaderFactory()

Method Details

newReader

public <T extends WritableChunk<Values>>
ChunkReader<T> newReader(@NotNull
 @NotNull BarrageTypeInfo<org.apache.arrow.flatbuf.Field> typeInfo,
 @NotNull
 @NotNull BarrageOptions options)

Description copied from interface: ChunkReader.Factory

Returns a ChunkReader for the specified arguments.

Specified by:

newReader in interface ChunkReader.Factory

Parameters:

typeInfo - the type of data to read into a chunk

options - options for reading the stream

Returns:

a ChunkReader based on the given options, factory, and type to read

extractChunkFromInputStream

public static <T> WritableObjectChunk<T,Values> extractChunkFromInputStream(DataInput is,
 Iterator<ChunkWriter.FieldNodeInfo> fieldNodeIter,
 PrimitiveIterator.OfLong bufferInfoIter,
 WebChunkReaderFactory.Mapper<T> mapper,
 WritableChunk<Values> outChunk,
 int outOffset,
 int totalRows)
                                                                     throws IOException

Throws:

IOException

transformToObject

public static <T,
WIRE_CHUNK_TYPE extends WritableChunk<Values>,
CR extends ChunkReader<WIRE_CHUNK_TYPE>>
ChunkReader<WritableObjectChunk<T,Values>> transformToObject(CR wireReader,
 BaseChunkReader.ChunkTransformer<WIRE_CHUNK_TYPE,WritableObjectChunk<T,Values>> wireTransform)