Package org.apache.iceberg.parquet
Class ParquetVariantReaders
java.lang.Object
org.apache.iceberg.parquet.ParquetVariantReaders
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionasVariant
(PhysicalType type, ParquetValueReader<?> reader) static ParquetValueReader<VariantMetadata>
metadata
(org.apache.parquet.column.ColumnDescriptor desc) objects
(int valueDefinitionLevel, ParquetValueReader<?> valueReader, int typedDefinitionLevel, List<String> fieldNames, List<ParquetVariantReaders.VariantValueReader> fieldReaders) serialized
(org.apache.parquet.column.ColumnDescriptor desc) shredded
(int valueDefinitionLevel, ParquetValueReader<?> valueReader, int typedDefinitionLevel, ParquetValueReader<?> typedReader) static ParquetValueReader<Variant>
variant
(ParquetValueReader<?> metadata, ParquetValueReader<?> value)
-
Method Details
-
variant
public static ParquetValueReader<Variant> variant(ParquetValueReader<?> metadata, ParquetValueReader<?> value) -
metadata
public static ParquetValueReader<VariantMetadata> metadata(org.apache.parquet.column.ColumnDescriptor desc) -
serialized
public static ParquetVariantReaders.VariantValueReader serialized(org.apache.parquet.column.ColumnDescriptor desc) -
shredded
public static ParquetVariantReaders.VariantValueReader shredded(int valueDefinitionLevel, ParquetValueReader<?> valueReader, int typedDefinitionLevel, ParquetValueReader<?> typedReader) -
objects
public static ParquetVariantReaders.VariantValueReader objects(int valueDefinitionLevel, ParquetValueReader<?> valueReader, int typedDefinitionLevel, List<String> fieldNames, List<ParquetVariantReaders.VariantValueReader> fieldReaders) -
asVariant
public static ParquetVariantReaders.VariantValueReader asVariant(PhysicalType type, ParquetValueReader<?> reader)
-