org.apache.iceberg.parquet

Class ParquetValueWriters

java.lang.Object

org.apache.iceberg.parquet.ParquetValueWriters

public class ParquetValueWriters
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ParquetValueWriters.PositionDeleteStructWriter<R>
static class	ParquetValueWriters.PrimitiveWriter<T>
static class	ParquetValueWriters.RepeatedKeyValueWriter<M,K,V>
static class	ParquetValueWriters.RepeatedWriter<L,E>
static class	ParquetValueWriters.StructWriter<S>

Method Summary

Modifier and Type	Method and Description
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Boolean>	booleans(org.apache.parquet.column.ColumnDescriptor desc)
static ParquetValueWriters.PrimitiveWriter<java.nio.ByteBuffer>	byteBuffers(org.apache.parquet.column.ColumnDescriptor desc)
static <E> org.apache.iceberg.parquet.ParquetValueWriters.CollectionWriter<E>	collections(int dl, int rl, ParquetValueWriter<E> writer)
static ParquetValueWriters.PrimitiveWriter<java.math.BigDecimal>	decimalAsFixed(org.apache.parquet.column.ColumnDescriptor desc, int precision, int scale)
static ParquetValueWriters.PrimitiveWriter<java.math.BigDecimal>	decimalAsInteger(org.apache.parquet.column.ColumnDescriptor desc, int precision, int scale)
static ParquetValueWriters.PrimitiveWriter<java.math.BigDecimal>	decimalAsLong(org.apache.parquet.column.ColumnDescriptor desc, int precision, int scale)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Double>	doubles(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Float>	floats(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Integer>	ints(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Long>	longs(org.apache.parquet.column.ColumnDescriptor desc)
static <K,V> org.apache.iceberg.parquet.ParquetValueWriters.MapWriter<K,V>	maps(int dl, int rl, ParquetValueWriter<K> keyWriter, ParquetValueWriter<V> valueWriter)
static <T> ParquetValueWriter<T>	option(org.apache.parquet.schema.Type type, int definitionLevel, ParquetValueWriter<T> writer)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Short>	shorts(org.apache.parquet.column.ColumnDescriptor desc)
static ParquetValueWriters.PrimitiveWriter<java.lang.CharSequence>	strings(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Byte>	tinyints(org.apache.parquet.column.ColumnDescriptor desc)

Methods inherited from class java.lang.Object

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

Method Detail

option

public static <T> ParquetValueWriter<T> option(org.apache.parquet.schema.Type type,
                                               int definitionLevel,
                                               ParquetValueWriter<T> writer)

booleans

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Boolean> booleans(org.apache.parquet.column.ColumnDescriptor desc)

tinyints

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Byte> tinyints(org.apache.parquet.column.ColumnDescriptor desc)

shorts

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Short> shorts(org.apache.parquet.column.ColumnDescriptor desc)

ints

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Integer> ints(org.apache.parquet.column.ColumnDescriptor desc)

longs

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Long> longs(org.apache.parquet.column.ColumnDescriptor desc)

floats

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Float> floats(org.apache.parquet.column.ColumnDescriptor desc)

doubles

public static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<java.lang.Double> doubles(org.apache.parquet.column.ColumnDescriptor desc)

strings

public static ParquetValueWriters.PrimitiveWriter<java.lang.CharSequence> strings(org.apache.parquet.column.ColumnDescriptor desc)

decimalAsInteger

public static ParquetValueWriters.PrimitiveWriter<java.math.BigDecimal> decimalAsInteger(org.apache.parquet.column.ColumnDescriptor desc,
                                                                                         int precision,
                                                                                         int scale)

decimalAsLong

public static ParquetValueWriters.PrimitiveWriter<java.math.BigDecimal> decimalAsLong(org.apache.parquet.column.ColumnDescriptor desc,
                                                                                      int precision,
                                                                                      int scale)

decimalAsFixed

public static ParquetValueWriters.PrimitiveWriter<java.math.BigDecimal> decimalAsFixed(org.apache.parquet.column.ColumnDescriptor desc,
                                                                                       int precision,
                                                                                       int scale)

byteBuffers

public static ParquetValueWriters.PrimitiveWriter<java.nio.ByteBuffer> byteBuffers(org.apache.parquet.column.ColumnDescriptor desc)

collections

public static <E> org.apache.iceberg.parquet.ParquetValueWriters.CollectionWriter<E> collections(int dl,
                                                                                                 int rl,
                                                                                                 ParquetValueWriter<E> writer)

maps

public static <K,V> org.apache.iceberg.parquet.ParquetValueWriters.MapWriter<K,V> maps(int dl,
                                                                                       int rl,
                                                                                       ParquetValueWriter<K> keyWriter,
                                                                                       ParquetValueWriter<V> valueWriter)