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

Constructor	Description
VectorizedReaderBuilder(Schema expectedSchema, org.apache.parquet.schema.MessageType parquetSchema, boolean setArrowValidityVector, java.util.Map<java.lang.Integer,?> idToConstant, java.util.function.Function<java.util.List<VectorizedReader<?>>,VectorizedReader<?>> readerFactory)

Method Summary

Modifier and Type	Method	Description
VectorizedReader<?>	message(Types.StructType expected, org.apache.parquet.schema.MessageType message, java.util.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, java.util.List<VectorizedReader<?>> fieldReaders)
protected VectorizedReader<?>	vectorizedReader(java.util.List<VectorizedReader<?>> reorderedFields)

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

currentPath, list, map, path, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorizedReaderBuilder

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

Method Detail

message

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

Overrides:

message in class TypeWithSchemaVisitor<VectorizedReader<?>>

vectorizedReader

protected VectorizedReader<?> vectorizedReader(java.util.List<VectorizedReader<?>> reorderedFields)

struct

public VectorizedReader<?> struct(Types.StructType expected,
                                  org.apache.parquet.schema.GroupType groupType,
                                  java.util.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<?>>