Uses of Interface
org.apache.flink.runtime.operators.util.JoinTaskIterator

Packages that use JoinTaskIterator

Package	Description
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.hash
org.apache.flink.runtime.operators.sort

Uses of JoinTaskIterator in org.apache.flink.runtime.operators

Fields in org.apache.flink.runtime.operators declared as JoinTaskIterator

Modifier and Type	Field and Description
protected JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.outerJoinIterator

Methods in org.apache.flink.runtime.operators that return JoinTaskIterator

Modifier and Type	Method and Description
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)

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

Classes in org.apache.flink.runtime.operators.hash that implement JoinTaskIterator

Modifier and Type	Class and Description
class	NonReusingBuildFirstHashJoinIterator<V1,V2,O> An implementation of the JoinTaskIterator that uses a hybrid-hash-join internally to match the records with equal key.
class	NonReusingBuildFirstReOpenableHashJoinIterator<V1,V2,O>
class	NonReusingBuildSecondHashJoinIterator<V1,V2,O> An implementation of the JoinTaskIterator that uses a hybrid-hash-join internally to match the records with equal key.
class	NonReusingBuildSecondReOpenableHashJoinIterator<V1,V2,O>
class	ReusingBuildFirstHashJoinIterator<V1,V2,O> An implementation of the JoinTaskIterator that uses a hybrid-hash-join internally to match the records with equal key.
class	ReusingBuildFirstReOpenableHashJoinIterator<V1,V2,O>
class	ReusingBuildSecondHashJoinIterator<V1,V2,O> An implementation of the JoinTaskIterator that uses a hybrid-hash-join internally to match the records with equal key.
class	ReusingBuildSecondReOpenableHashJoinIterator<V1,V2,O>

Uses of JoinTaskIterator in org.apache.flink.runtime.operators.sort

Classes in org.apache.flink.runtime.operators.sort that implement JoinTaskIterator

Modifier and Type	Class and Description
class	AbstractMergeInnerJoinIterator<T1,T2,O> An implementation of the JoinTaskIterator that realizes the joining through a sort-merge join strategy.
class	AbstractMergeIterator<T1,T2,O>
class	AbstractMergeOuterJoinIterator<T1,T2,O> An implementation of the JoinTaskIterator that realizes the outer join through a sort-merge join strategy.
class	NonReusingMergeInnerJoinIterator<T1,T2,O>
class	NonReusingMergeOuterJoinIterator<T1,T2,O>
class	ReusingMergeInnerJoinIterator<T1,T2,O>
class	ReusingMergeOuterJoinIterator<T1,T2,O>