org.apache.iceberg.parquet

Class ParquetValueWriters.RepeatedWriter<L,E>

java.lang.Object

org.apache.iceberg.parquet.ParquetValueWriters.RepeatedWriter<L,E>

All Implemented Interfaces:

ParquetValueWriter<L>

Enclosing class:

ParquetValueWriters

public abstract static class ParquetValueWriters.RepeatedWriter<L,E>
extends java.lang.Object
implements ParquetValueWriter<L>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RepeatedWriter(int definitionLevel, int repetitionLevel, ParquetValueWriter<E> writer)

Method Summary

Modifier and Type	Method and Description
java.util.List<TripleWriter<?>>	columns()
protected abstract java.util.Iterator<E>	elements(L value)
java.util.stream.Stream<FieldMetrics>	metrics() Returns a stream of FieldMetrics that this ParquetValueWriter keeps track of.
void	setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
void	write(int parentRepetition, L value)

Methods inherited from class java.lang.Object

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

Constructor Detail

RepeatedWriter

protected RepeatedWriter(int definitionLevel,
                         int repetitionLevel,
                         ParquetValueWriter<E> writer)

Method Detail

write

public void write(int parentRepetition,
                  L value)

Specified by:

write in interface ParquetValueWriter<L>

columns

public java.util.List<TripleWriter<?>> columns()

Specified by:

columns in interface ParquetValueWriter<L>

setColumnStore

public void setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)

Specified by:

setColumnStore in interface ParquetValueWriter<L>

elements

protected abstract java.util.Iterator<E> elements(L value)

metrics

public java.util.stream.Stream<FieldMetrics> metrics()

Description copied from interface: ParquetValueWriter

Returns a stream of FieldMetrics that this ParquetValueWriter keeps track of.

Since Parquet keeps track of most metrics in its footer, for now ParquetValueWriter only keeps track of NaN counter, and only return non-empty stream if the writer writes double or float values either by itself or transitively.

Specified by:

metrics in interface ParquetValueWriter<L>