public abstract static class ParquetValueWriters.RepeatedKeyValueWriter<M,K,V> extends java.lang.Object implements ParquetValueWriter<M>
Modifier | Constructor and Description |
---|---|
protected |
RepeatedKeyValueWriter(int definitionLevel,
int repetitionLevel,
ParquetValueWriter<K> keyWriter,
ParquetValueWriter<V> valueWriter) |
Modifier and Type | Method and Description |
---|---|
java.util.List<TripleWriter<?>> |
columns() |
java.util.stream.Stream<FieldMetrics<?>> |
metrics()
Returns a stream of
FieldMetrics 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) |
protected RepeatedKeyValueWriter(int definitionLevel, int repetitionLevel, ParquetValueWriter<K> keyWriter, ParquetValueWriter<V> valueWriter)
public void write(int parentRepetition, M value)
write
in interface ParquetValueWriter<M>
public java.util.List<TripleWriter<?>> columns()
columns
in interface ParquetValueWriter<M>
public void setColumnStore(org.apache.parquet.column.ColumnWriteStore columnStore)
setColumnStore
in interface ParquetValueWriter<M>
public java.util.stream.Stream<FieldMetrics<?>> metrics()
ParquetValueWriter
FieldMetrics
that this ParquetValueWriter keeps track of.metrics
in interface ParquetValueWriter<M>