Package org.apache.iceberg.util

Class PartitionMap<V>

java.lang.Object

java.util.AbstractMap<Pair<Integer,StructLike>,V>

org.apache.iceberg.util.PartitionMap<V>

Type Parameters:

V - the type of values

All Implemented Interfaces:

Map<Pair<Integer,StructLike>,V>

public class PartitionMap<V>
extends AbstractMap<Pair<Integer,StructLike>,V>

A map that uses a pair of spec ID and partition tuple as keys.

This implementation internally stores provided partition tuples in StructLikeMap for consistent hashing and equals behavior. This ensures that objects of different types that represent the same structs are treated as equal keys in the map.

Note: This map is not designed for concurrent modification by multiple threads. However, it supports safe concurrent reads, assuming there are no concurrent writes.

Note: This map does not support null pairs but supports null as partition tuples.

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Method Summary

Modifier and Type	Method	Description
void	clear()
V	computeIfAbsent(int specId, StructLike struct, Supplier<V> valueSupplier)
boolean	containsKey(int specId, StructLike struct)
boolean	containsKey(Object key)
boolean	containsValue(Object value)
static <T> PartitionMap<T>	create(Map<Integer,PartitionSpec> specs)
Set<Map.Entry<Pair<Integer,StructLike>,V>>	entrySet()
V	get(int specId, StructLike struct)
V	get(Object key)
boolean	isEmpty()
Set<Pair<Integer,StructLike>>	keySet()
V	put(int specId, StructLike struct, V value)
V	put(Pair<Integer,StructLike> key, V value)
void	putAll(Map<? extends Pair<Integer,StructLike>,? extends V> otherMap)
V	remove(Object key)
V	removeKey(int specId, StructLike struct)
int	size()
String	toString()
Collection<V>	values()

Methods inherited from class java.util.AbstractMap

clone, equals, hashCode

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Method Details

create

public static <T> PartitionMap<T> create(Map<Integer,PartitionSpec> specs)

size

public int size()

Specified by:

size in interface Map<Pair<Integer,StructLike>,V>

Overrides:

size in class AbstractMap<Pair<Integer,StructLike>,V>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map<Pair<Integer,StructLike>,V>

Overrides:

isEmpty in class AbstractMap<Pair<Integer,StructLike>,V>

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map<Pair<Integer,StructLike>,V>

Overrides:

containsKey in class AbstractMap<Pair<Integer,StructLike>,V>

containsKey

public boolean containsKey(int specId,
 StructLike struct)

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<Pair<Integer,StructLike>,V>

Overrides:

containsValue in class AbstractMap<Pair<Integer,StructLike>,V>

get

public V get(Object key)

Specified by:

get in interface Map<Pair<Integer,StructLike>,V>

Overrides:

get in class AbstractMap<Pair<Integer,StructLike>,V>

get

public V get(int specId,
 StructLike struct)

put

public V put(Pair<Integer,StructLike> key,
 V value)

Specified by:

put in interface Map<Pair<Integer,StructLike>,V>

Overrides:

put in class AbstractMap<Pair<Integer,StructLike>,V>

put

public V put(int specId,
 StructLike struct,
 V value)

putAll

public void putAll(Map<? extends Pair<Integer,StructLike>,? extends V> otherMap)

Specified by:

putAll in interface Map<Pair<Integer,StructLike>,V>

Overrides:

putAll in class AbstractMap<Pair<Integer,StructLike>,V>

remove

public V remove(Object key)

Specified by:

remove in interface Map<Pair<Integer,StructLike>,V>

Overrides:

remove in class AbstractMap<Pair<Integer,StructLike>,V>

removeKey

public V removeKey(int specId,
 StructLike struct)

clear

public void clear()

Specified by:

clear in interface Map<Pair<Integer,StructLike>,V>

Overrides:

clear in class AbstractMap<Pair<Integer,StructLike>,V>

keySet

public Set<Pair<Integer,StructLike>> keySet()

Specified by:

keySet in interface Map<Pair<Integer,StructLike>,V>

Overrides:

keySet in class AbstractMap<Pair<Integer,StructLike>,V>

values

public Collection<V> values()

Specified by:

values in interface Map<Pair<Integer,StructLike>,V>

Overrides:

values in class AbstractMap<Pair<Integer,StructLike>,V>

entrySet

public Set<Map.Entry<Pair<Integer,StructLike>,V>> entrySet()

Specified by:

entrySet in interface Map<Pair<Integer,StructLike>,V>

Specified by:

entrySet in class AbstractMap<Pair<Integer,StructLike>,V>

computeIfAbsent

public V computeIfAbsent(int specId,
 StructLike struct,
 Supplier<V> valueSupplier)

toString

public String toString()

Overrides:

toString in class AbstractMap<Pair<Integer,StructLike>,V>