Package org.apache.iceberg.parquet
Class ParquetValueReaders.RepeatedKeyValueReader<M,I,K,V>
- java.lang.Object
-
- org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader<M,I,K,V>
-
- All Implemented Interfaces:
ParquetValueReader<M>
- Direct Known Subclasses:
ParquetValueReaders.MapReader
- Enclosing class:
- ParquetValueReaders
public abstract static class ParquetValueReaders.RepeatedKeyValueReader<M,I,K,V> extends java.lang.Object implements ParquetValueReader<M>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
RepeatedKeyValueReader(int definitionLevel, int repetitionLevel, ParquetValueReader<K> keyReader, ParquetValueReader<V> valueReader)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Constructor Detail
-
RepeatedKeyValueReader
protected RepeatedKeyValueReader(int definitionLevel, int repetitionLevel, ParquetValueReader<K> keyReader, ParquetValueReader<V> valueReader)
-
-
Method Detail
-
setPageSource
public void setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
- Specified by:
setPageSource
in interfaceParquetValueReader<M>
-
column
public org.apache.iceberg.parquet.TripleIterator<?> column()
- Specified by:
column
in interfaceParquetValueReader<M>
-
read
public M read(M reuse)
- Specified by:
read
in interfaceParquetValueReader<M>
-
columns
public java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> columns()
- Specified by:
columns
in interfaceParquetValueReader<M>
-
-