org.apache.iceberg.parquet

Interface ParquetValueWriter<T>

All Known Implementing Classes:

ParquetValueWriters.PositionDeleteStructWriter, ParquetValueWriters.PrimitiveWriter, ParquetValueWriters.RepeatedKeyValueWriter, ParquetValueWriters.RepeatedWriter, ParquetValueWriters.StructWriter

public interface ParquetValueWriter<T>

Method Summary

Modifier and Type	Method and Description
java.util.List<TripleWriter<?>>	columns()
default 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, T value)

Method Detail

write

void write(int repetitionLevel,
           T value)

columns

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

setColumnStore

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

metrics

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

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.