Package io.deephaven.extensions.barrage.util

Class BarrageUtil.ConvertedArrowSchema

java.lang.Object

io.deephaven.extensions.barrage.util.BarrageUtil.ConvertedArrowSchema

Enclosing class:

BarrageUtil

public static class BarrageUtil.ConvertedArrowSchema
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
Map<String,Object>	attributes
int[]	conversionFactors
final int	nCols
TableDefinition	tableDef

Constructor Summary

Constructors

Constructor	Description
ConvertedArrowSchema(int nCols)

Method Summary

Modifier and Type	Method	Description
ChunkReader[]	computeChunkReaders(ChunkReader.Factory chunkReaderFactory, org.apache.arrow.flatbuf.Schema schema, @NotNull StreamReaderOptions barrageOptions)
ChunkType[]	computeWireChunkTypes()
Class<?>[]	computeWireComponentTypes()
Class<?>[]	computeWireTypes()

Methods inherited from class java.lang.Object

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

Field Details

nCols

public final int nCols

tableDef

public TableDefinition tableDef

conversionFactors

public int[] conversionFactors

attributes

public Map<String,Object> attributes

Constructor Details

ConvertedArrowSchema

public ConvertedArrowSchema(int nCols)

Method Details

computeWireChunkTypes

public ChunkType[] computeWireChunkTypes()

computeWireTypes

public Class<?>[] computeWireTypes()

computeWireComponentTypes

public Class<?>[] computeWireComponentTypes()

computeChunkReaders

public ChunkReader[] computeChunkReaders(@NotNull
 ChunkReader.Factory chunkReaderFactory,
 @NotNull
 org.apache.arrow.flatbuf.Schema schema,
 @NotNull
 @NotNull StreamReaderOptions barrageOptions)