Uses of Class
org.apache.flink.runtime.operators.hash.HashPartition

Packages that use HashPartition

Package	Description
org.apache.flink.runtime.iterative.io
org.apache.flink.runtime.operators.hash

Uses of HashPartition in org.apache.flink.runtime.iterative.io

Constructor parameters in org.apache.flink.runtime.iterative.io with type arguments of type HashPartition

Constructor and Description
HashPartitionIterator(Iterator<HashPartition<BT,PT>> partitions, TypeSerializer<BT> serializer)

Uses of HashPartition in org.apache.flink.runtime.operators.hash

Subclasses of HashPartition in org.apache.flink.runtime.operators.hash

Modifier and Type	Class and Description
class	ReOpenableHashPartition<BT,PT>

Fields in org.apache.flink.runtime.operators.hash with type parameters of type HashPartition

Modifier and Type	Field and Description
protected ArrayList<HashPartition<BT,PT>>	MutableHashTable.partitionsBeingBuilt The partitions that are built by processing the current partition.

Methods in org.apache.flink.runtime.operators.hash that return HashPartition

Modifier and Type	Method and Description
protected HashPartition<BT,PT>	MutableHashTable.getNewInMemoryPartition(int number, int recursionLevel) Returns a new inMemoryPartition object.
protected HashPartition<BT,PT>	ReOpenableMutableHashTable.getNewInMemoryPartition(int number, int recursionLevel)

Methods in org.apache.flink.runtime.operators.hash with parameters of type HashPartition

Modifier and Type	Method and Description
protected void	MutableHashTable.buildBloomFilterForBucketsInPartition(int partNum, HashPartition<BT,PT> partition)
protected void	MutableHashTable.buildTableFromSpilledPartition(HashPartition<BT,PT> p)

Method parameters in org.apache.flink.runtime.operators.hash with type arguments of type HashPartition

Modifier and Type	Method and Description
int	ReOpenableHashPartition.finalizeProbePhase(List<MemorySegment> freeMemory, List<HashPartition<BT,PT>> spilledPartitions, boolean keepUnprobedSpilledPartitions)
int	HashPartition.finalizeProbePhase(List<MemorySegment> freeMemory, List<HashPartition<BT,PT>> spilledPartitions, boolean keepUnprobedSpilledPartitions)