Package org.apache.iceberg.parquet

Class ParquetValueReaders.MapReader<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

ParquetValueReader<Map<K,V>>

Enclosing class:

ParquetValueReaders

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	addPair(Map<K,V> map, K key, V value)
protected Map<K,V>	buildMap(Map<K,V> map)
protected Map.Entry<K,V>	getPair(Map<K,V> map)
protected Map<K,V>	newMapData(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 Details

MapReader

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

Method Details

newMapData

protected Map<K,V> newMapData(Map<K,V> reuse)

Specified by:

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

getPair

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

Specified by:

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

addPair

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

Specified by:

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

buildMap

protected Map<K,V> buildMap(Map<K,V> map)

Specified by:

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