Package org.apache.iceberg.arrow.vectorized

Class VectorizedReaderBuilder

java.lang.Object

org.apache.iceberg.parquet.TypeWithSchemaVisitor<VectorizedReader<?>>

org.apache.iceberg.arrow.vectorized.VectorizedReaderBuilder

public class VectorizedReaderBuilder
extends TypeWithSchemaVisitor<VectorizedReader<?>>

Field Summary

Fields inherited from class org.apache.iceberg.parquet.TypeWithSchemaVisitor

fieldNames

Constructor Summary

Constructors

Modifier	Constructor	Description
	VectorizedReaderBuilder(Schema expectedSchema, org.apache.parquet.schema.MessageType parquetSchema, boolean setArrowValidityVector, Map<Integer,?> idToConstant, Function<List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory)
protected	VectorizedReaderBuilder(Schema expectedSchema, org.apache.parquet.schema.MessageType parquetSchema, boolean setArrowValidityVector, Map<Integer,?> idToConstant, Function<List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory, BiFunction<Type,Object,Object> convert)
protected	VectorizedReaderBuilder(Schema expectedSchema, org.apache.parquet.schema.MessageType parquetSchema, boolean setArrowValidityVector, Map<Integer,?> idToConstant, Function<List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory, BiFunction<Type,Object,Object> convert, org.apache.arrow.memory.BufferAllocator bufferAllocator)

Method Summary

Modifier and Type	Method	Description
VectorizedReader<?>	message(Types.StructType expected, org.apache.parquet.schema.MessageType message, List<VectorizedReader<?>> fieldReaders)
VectorizedReader<?>	primitive(Type.PrimitiveType expected, org.apache.parquet.schema.PrimitiveType primitive)
VectorizedReader<?>	struct(Types.StructType expected, org.apache.parquet.schema.GroupType groupType, List<VectorizedReader<?>> fieldReaders)
protected VectorizedReader<?>	vectorizedReader(List<VectorizedReader<?>> reorderedFields)

Methods inherited from class org.apache.iceberg.parquet.TypeWithSchemaVisitor

currentPath, list, map, path, variant, variantVisitor, visit

Methods inherited from class java.lang.Object

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

Constructor Details

VectorizedReaderBuilder

public VectorizedReaderBuilder(Schema expectedSchema,
 org.apache.parquet.schema.MessageType parquetSchema,
 boolean setArrowValidityVector,
 Map<Integer,?> idToConstant,
 Function<List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory)

VectorizedReaderBuilder

protected VectorizedReaderBuilder(Schema expectedSchema,
 org.apache.parquet.schema.MessageType parquetSchema,
 boolean setArrowValidityVector,
 Map<Integer,?> idToConstant,
 Function<List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory,
 BiFunction<Type,Object,Object> convert)

VectorizedReaderBuilder

protected VectorizedReaderBuilder(Schema expectedSchema,
 org.apache.parquet.schema.MessageType parquetSchema,
 boolean setArrowValidityVector,
 Map<Integer,?> idToConstant,
 Function<List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory,
 BiFunction<Type,Object,Object> convert,
 org.apache.arrow.memory.BufferAllocator bufferAllocator)

Method Details

message

public VectorizedReader<?> message(Types.StructType expected,
 org.apache.parquet.schema.MessageType message,
 List<VectorizedReader<?>> fieldReaders)

Overrides:

message in class TypeWithSchemaVisitor<VectorizedReader<?>>

vectorizedReader

protected VectorizedReader<?> vectorizedReader(List<VectorizedReader<?>> reorderedFields)

struct

public VectorizedReader<?> struct(Types.StructType expected,
 org.apache.parquet.schema.GroupType groupType,
 List<VectorizedReader<?>> fieldReaders)

Overrides:

struct in class TypeWithSchemaVisitor<VectorizedReader<?>>

primitive

public VectorizedReader<?> primitive(Type.PrimitiveType expected,
 org.apache.parquet.schema.PrimitiveType primitive)

Overrides:

primitive in class TypeWithSchemaVisitor<VectorizedReader<?>>