org.apache.iceberg.parquet

Class ParquetValueReaders.MapReader<K,V>

java.lang.Object

org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader<java.util.Map<K,V>,java.util.Map<K,V>,K,V>

org.apache.iceberg.parquet.ParquetValueReaders.MapReader<K,V>

All Implemented Interfaces:

ParquetValueReader<java.util.Map<K,V>>

Enclosing class:

ParquetValueReaders

public static class ParquetValueReaders.MapReader<K,V>
extends ParquetValueReaders.RepeatedKeyValueReader<java.util.Map<K,V>,java.util.Map<K,V>,K,V>

Constructor Summary

Constructors

Constructor and Description
MapReader(int definitionLevel, int repetitionLevel, ParquetValueReader<K> keyReader, ParquetValueReader<V> valueReader)

Method Summary

Modifier and Type	Method and Description
protected void	addPair(java.util.Map<K,V> map, K key, V value)
protected java.util.Map<K,V>	buildMap(java.util.Map<K,V> map)
protected java.util.Map.Entry<K,V>	getPair(java.util.Map<K,V> map)
protected java.util.Map<K,V>	newMapData(java.util.Map<K,V> reuse)

Methods inherited from class org.apache.iceberg.parquet.ParquetValueReaders.RepeatedKeyValueReader

column, columns, read, setPageSource

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapReader

public MapReader(int definitionLevel,
                 int repetitionLevel,
                 ParquetValueReader<K> keyReader,
                 ParquetValueReader<V> valueReader)

Method Detail

newMapData

protected java.util.Map<K,V> newMapData(java.util.Map<K,V> reuse)

Specified by:

newMapData in class ParquetValueReaders.RepeatedKeyValueReader<java.util.Map<K,V>,java.util.Map<K,V>,K,V>

getPair

protected java.util.Map.Entry<K,V> getPair(java.util.Map<K,V> map)

Specified by:

getPair in class ParquetValueReaders.RepeatedKeyValueReader<java.util.Map<K,V>,java.util.Map<K,V>,K,V>

addPair

protected void addPair(java.util.Map<K,V> map,
                       K key,
                       V value)

Specified by:

addPair in class ParquetValueReaders.RepeatedKeyValueReader<java.util.Map<K,V>,java.util.Map<K,V>,K,V>

buildMap

protected java.util.Map<K,V> buildMap(java.util.Map<K,V> map)

Specified by:

buildMap in class ParquetValueReaders.RepeatedKeyValueReader<java.util.Map<K,V>,java.util.Map<K,V>,K,V>