Package org.apache.iceberg.parquet
Class ParquetValueWriters.RepeatedKeyValueWriter<M,K,V>
- java.lang.Object
-
- org.apache.iceberg.parquet.ParquetValueWriters.RepeatedKeyValueWriter<M,K,V>
-
- All Implemented Interfaces:
ParquetValueWriter<M>
- Enclosing class:
- ParquetValueWriters
public abstract static class ParquetValueWriters.RepeatedKeyValueWriter<M,K,V> extends java.lang.Object implements ParquetValueWriter<M>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
RepeatedKeyValueWriter(int definitionLevel, int repetitionLevel, ParquetValueWriter<K> keyWriter, ParquetValueWriter<V> valueWriter)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description java.util.List<TripleWriter<?>>
columns()
java.util.stream.Stream<FieldMetrics<?>>
metrics()
Returns a stream ofFieldMetrics
that this ParquetValueWriter keeps track of.protected abstract java.util.Iterator<java.util.Map.Entry<K,V>>
pairs(M value)
void
setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
void
write(int parentRepetition, M value)
-
-
-
Constructor Detail
-
RepeatedKeyValueWriter
protected RepeatedKeyValueWriter(int definitionLevel, int repetitionLevel, ParquetValueWriter<K> keyWriter, ParquetValueWriter<V> valueWriter)
-
-
Method Detail
-
write
public void write(int parentRepetition, M value)
- Specified by:
write
in interfaceParquetValueWriter<M>
-
columns
public java.util.List<TripleWriter<?>> columns()
- Specified by:
columns
in interfaceParquetValueWriter<M>
-
setColumnStore
public void setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
- Specified by:
setColumnStore
in interfaceParquetValueWriter<M>
-
metrics
public java.util.stream.Stream<FieldMetrics<?>> metrics()
Description copied from interface:ParquetValueWriter
Returns a stream ofFieldMetrics
that this ParquetValueWriter keeps track of.- Specified by:
metrics
in interfaceParquetValueWriter<M>
-
-