public abstract static class ParquetValueReaders.RepeatedKeyValueReader<M,I,K,V> extends java.lang.Object implements ParquetValueReader<M>
Modifier | Constructor and Description |
---|---|
protected |
RepeatedKeyValueReader(int definitionLevel,
int repetitionLevel,
ParquetValueReader<K> keyReader,
ParquetValueReader<V> valueReader) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
addPair(I map,
K key,
V value) |
protected abstract M |
buildMap(I map) |
org.apache.iceberg.parquet.TripleIterator<?> |
column() |
java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> |
columns() |
protected abstract java.util.Map.Entry<K,V> |
getPair(I map) |
protected abstract I |
newMapData(M reuse) |
M |
read(M reuse) |
void |
setPageSource(org.apache.parquet.column.page.PageReadStore pageStore,
long rowPosition) |
protected RepeatedKeyValueReader(int definitionLevel, int repetitionLevel, ParquetValueReader<K> keyReader, ParquetValueReader<V> valueReader)
public void setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
setPageSource
in interface ParquetValueReader<M>
public org.apache.iceberg.parquet.TripleIterator<?> column()
column
in interface ParquetValueReader<M>
public M read(M reuse)
read
in interface ParquetValueReader<M>
public java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> columns()
columns
in interface ParquetValueReader<M>