org.apache.iceberg.parquet

Class ParquetValueWriters.StructWriter<S>

java.lang.Object

org.apache.iceberg.parquet.ParquetValueWriters.StructWriter<S>

All Implemented Interfaces:

ParquetValueWriter<S>

Direct Known Subclasses:

ParquetValueWriters.PositionDeleteStructWriter

Enclosing class:

ParquetValueWriters

public abstract static class ParquetValueWriters.StructWriter<S>
extends java.lang.Object
implements ParquetValueWriter<S>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StructWriter(java.util.List<ParquetValueWriter<?>> writers)

Method Summary

Modifier and Type	Method and Description
java.util.List<TripleWriter<?>>	columns()
protected abstract java.lang.Object	get(S struct, int index)
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 repetitionLevel, S value)

Methods inherited from class java.lang.Object

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

Constructor Detail

StructWriter

protected StructWriter(java.util.List<ParquetValueWriter<?>> writers)

Method Detail

write

public void write(int repetitionLevel,
                  S value)

Specified by:

write in interface ParquetValueWriter<S>

columns

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

Specified by:

columns in interface ParquetValueWriter<S>

setColumnStore

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

Specified by:

setColumnStore in interface ParquetValueWriter<S>

get

protected abstract java.lang.Object get(S struct,
                                        int index)

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<S>