Package io.deephaven.extensions.barrage.chunk

Class DefaultChunkReaderFactory

java.lang.Object

io.deephaven.extensions.barrage.chunk.DefaultChunkReaderFactory

All Implemented Interfaces:

ChunkReader.Factory

public class DefaultChunkReaderFactory
extends Object
implements ChunkReader.Factory

JVM implementation of ChunkReader.Factory, suitable for use in Java clients and servers. This default implementation may not round trip flight types in a stable way, but will round trip Deephaven table definitions and table data. Neither of these is a required/expected property of being a Flight/Barrage/Deephaven client.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DefaultChunkReaderFactory.ChunkReaderFactory	Factory method to create a new ChunkReader for the given type and options.

Field Summary

Fields

Modifier and Type	Field	Description
static final DefaultChunkReaderFactory	INSTANCE
static final Logger	log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultChunkReaderFactory()

Method Summary

Modifier and Type	Method	Description
protected Map<Class<?>,DefaultChunkReaderFactory.ChunkReaderFactory>	lookupReaderFactory(org.apache.arrow.vector.types.pojo.ArrowType.ArrowTypeID typeId)
<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.
<T extends WritableChunk<Values>> ChunkReader<T>	newReaderPojo(@NotNull BarrageTypeInfo<org.apache.arrow.vector.types.pojo.Field> typeInfo, @NotNull BarrageOptions options, boolean isTopLevel)
void	register(org.apache.arrow.vector.types.pojo.ArrowType.ArrowTypeID arrowType, Class<?> deephavenType, DefaultChunkReaderFactory.ChunkReaderFactory chunkReaderFactory)
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

Field Details

log

public static final Logger log

INSTANCE

public static final DefaultChunkReaderFactory INSTANCE

Constructor Details

DefaultChunkReaderFactory

protected DefaultChunkReaderFactory()

Method Details

lookupReaderFactory

protected Map<Class<?>,DefaultChunkReaderFactory.ChunkReaderFactory> lookupReaderFactory(org.apache.arrow.vector.types.pojo.ArrowType.ArrowTypeID typeId)

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

newReaderPojo

public <T extends WritableChunk<Values>>
ChunkReader<T> newReaderPojo(@NotNull
 @NotNull BarrageTypeInfo<org.apache.arrow.vector.types.pojo.Field> typeInfo,
 @NotNull
 @NotNull BarrageOptions options,
 boolean isTopLevel)

register

public void register(org.apache.arrow.vector.types.pojo.ArrowType.ArrowTypeID arrowType,
 Class<?> deephavenType,
 DefaultChunkReaderFactory.ChunkReaderFactory chunkReaderFactory)

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)