org.apache.flink.runtime.operators.hash

Class HashJoinIteratorBase

java.lang.Object

org.apache.flink.runtime.operators.hash.HashJoinIteratorBase

Direct Known Subclasses:

NonReusingBuildFirstHashJoinIterator, NonReusingBuildSecondHashJoinIterator, ReusingBuildFirstHashJoinIterator, ReusingBuildSecondHashJoinIterator

public class HashJoinIteratorBase
extends Object

Common methods for all Hash Join Iterators.

Constructor Summary

Constructors

Constructor and Description
HashJoinIteratorBase()

Method Summary

Modifier and Type	Method and Description
<BT,PT> MutableHashTable<BT,PT>	getHashJoin(TypeSerializer<BT> buildSideSerializer, TypeComparator<BT> buildSideComparator, TypeSerializer<PT> probeSideSerializer, TypeComparator<PT> probeSideComparator, TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean useBloomFilters)

Methods inherited from class java.lang.Object

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

Constructor Detail

HashJoinIteratorBase

public HashJoinIteratorBase()

Method Detail

getHashJoin

public <BT,PT> MutableHashTable<BT,PT> getHashJoin(TypeSerializer<BT> buildSideSerializer,
                                                   TypeComparator<BT> buildSideComparator,
                                                   TypeSerializer<PT> probeSideSerializer,
                                                   TypeComparator<PT> probeSideComparator,
                                                   TypePairComparator<PT,BT> pairComparator,
                                                   MemoryManager memManager,
                                                   IOManager ioManager,
                                                   AbstractInvokable ownerTask,
                                                   double memoryFraction,
                                                   boolean useBloomFilters)
                                            throws MemoryAllocationException

Throws:

MemoryAllocationException