com.hazelcast.internal.util.collection

Class PartitionIdSet

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractSet<Integer>

com.hazelcast.internal.util.collection.PartitionIdSet

All Implemented Interfaces:

Iterable<Integer>, Collection<Integer>, Set<Integer>

Direct Known Subclasses:

ImmutablePartitionIdSet

public class PartitionIdSet
extends AbstractSet<Integer>

A mutable set of partition IDs. Since partition IDs are integers in a range [0..partitionCount), a set of partition IDs can be efficiently represented by a fixed-size BitSet whose value at a particular index is set when that partition ID is present in the set. This offers better performance than a general purpose Set<Integer> implementation and better memory efficiency in most cases.

Additionally, the PartitionIdSet supplies specialized methods for add, remove and contains of primitive int arguments, as well as a primitive int iterator implementation, to allow clients avoid cost of boxing and unboxing.

This set's iterator is a view of the actual set, so any changes on the set will be reflected in the iterator and vice versa.

This class is not thread-safe.

Constructor Summary

Constructors

Constructor and Description
PartitionIdSet(int partitionCount)
PartitionIdSet(int partitionCount, Collection<Integer> initialPartitionIds)
PartitionIdSet(PartitionIdSet initialPartitionIds)

Method Summary

Modifier and Type	Method and Description
boolean	add(int partitionId)
boolean	add(Integer partitionId)
void	addAll(PartitionIdSet other)
void	clear()
void	complement() Mutates this set so it contains its complement with respect to the universe of all partition IDs.
boolean	contains(int partitionId)
boolean	contains(Object o)
boolean	containsAll(PartitionIdSet other)
int	getPartitionCount()
boolean	intersects(PartitionIdSet other) Returns whether the intersection of this set with given argument is not empty.
PrimitiveIterator.OfInt	intIterator()
boolean	isEmpty()
boolean	isMissingPartitions()
Iterator<Integer>	iterator()
boolean	remove(int partitionId)
boolean	remove(Object o)
void	removeAll(PartitionIdSet other)
int	size()
void	union(PartitionIdSet other) Mutates this PartitionIdSet so it contains the union of this and other's partition IDs.

Methods inherited from class java.util.AbstractSet

equals, hashCode, removeAll

Methods inherited from class java.util.AbstractCollection

addAll, containsAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Set

addAll, containsAll, retainAll, spliterator, toArray, toArray

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

PartitionIdSet

public PartitionIdSet(int partitionCount)

PartitionIdSet

public PartitionIdSet(int partitionCount,
                      Collection<Integer> initialPartitionIds)

PartitionIdSet

public PartitionIdSet(PartitionIdSet initialPartitionIds)

Method Detail

iterator

public Iterator<Integer> iterator()

Specified by:

iterator in interface Iterable<Integer>

Specified by:

iterator in interface Collection<Integer>

Specified by:

iterator in interface Set<Integer>

Specified by:

iterator in class AbstractCollection<Integer>

intIterator

public PrimitiveIterator.OfInt intIterator()

size

public int size()

Specified by:

size in interface Collection<Integer>

Specified by:

size in interface Set<Integer>

Specified by:

size in class AbstractCollection<Integer>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<Integer>

Specified by:

isEmpty in interface Set<Integer>

Overrides:

isEmpty in class AbstractCollection<Integer>

contains

public boolean contains(Object o)

Specified by:

contains in interface Collection<Integer>

Specified by:

contains in interface Set<Integer>

Overrides:

contains in class AbstractCollection<Integer>

contains

public boolean contains(int partitionId)

containsAll

public boolean containsAll(PartitionIdSet other)

Returns:

true when this set contains all partition IDs contained in other

add

public boolean add(Integer partitionId)

Specified by:

add in interface Collection<Integer>

Specified by:

add in interface Set<Integer>

Overrides:

add in class AbstractCollection<Integer>

add

public boolean add(int partitionId)

addAll

public void addAll(PartitionIdSet other)

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<Integer>

Specified by:

remove in interface Set<Integer>

Overrides:

remove in class AbstractCollection<Integer>

remove

public boolean remove(int partitionId)

removeAll

public void removeAll(PartitionIdSet other)

clear

public void clear()

Specified by:

clear in interface Collection<Integer>

Specified by:

clear in interface Set<Integer>

Overrides:

clear in class AbstractCollection<Integer>

getPartitionCount

public int getPartitionCount()

intersects

public boolean intersects(PartitionIdSet other)

Returns whether the intersection of this set with given argument is not empty.

Returns:

true when the intersection of this and other set is not empty, otherwise false.

union

public void union(PartitionIdSet other)

Mutates this PartitionIdSet so it contains the union of this and other's partition IDs.

complement

public void complement()

Mutates this set so it contains its complement with respect to the universe of all partition IDs.

isMissingPartitions

public boolean isMissingPartitions()

Returns:

false when all partition IDs in [0, partitionCount) are contained in this set, otherwise true