Package org.apache.iceberg.parquet

Class ParquetValueWriters

java.lang.Object

org.apache.iceberg.parquet.ParquetValueWriters

public class ParquetValueWriters
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<Boolean>	booleans(org.apache.parquet.column.ColumnDescriptor desc)
static ParquetValueWriters.PrimitiveWriter<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<BigDecimal>	decimalAsFixed(org.apache.parquet.column.ColumnDescriptor desc, int precision, int scale)
static ParquetValueWriters.PrimitiveWriter<BigDecimal>	decimalAsInteger(org.apache.parquet.column.ColumnDescriptor desc, int precision, int scale)
static ParquetValueWriters.PrimitiveWriter<BigDecimal>	decimalAsLong(org.apache.parquet.column.ColumnDescriptor desc, int precision, int scale)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<Double>	doubles(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<Float>	floats(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<Integer>	ints(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<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<Short>	shorts(org.apache.parquet.column.ColumnDescriptor desc)
static ParquetValueWriters.PrimitiveWriter<CharSequence>	strings(org.apache.parquet.column.ColumnDescriptor desc)
static org.apache.iceberg.parquet.ParquetValueWriters.UnboxedWriter<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 Details

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<Boolean> booleans(org.apache.parquet.column.ColumnDescriptor desc)

tinyints

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

shorts

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

ints

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

longs

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

floats

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

doubles

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

strings

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

decimalAsInteger

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

decimalAsLong

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

decimalAsFixed

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

byteBuffers

public static ParquetValueWriters.PrimitiveWriter<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)