Class FullOuterJoinDriver<IT1,IT2,OT>
- java.lang.Object
-
- org.apache.flink.runtime.operators.AbstractOuterJoinDriver<IT1,IT2,OT>
-
- org.apache.flink.runtime.operators.FullOuterJoinDriver<IT1,IT2,OT>
-
- All Implemented Interfaces:
Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
public class FullOuterJoinDriver<IT1,IT2,OT> extends AbstractOuterJoinDriver<IT1,IT2,OT>
The full outer join driver implements the logic of an outer join operator at runtime. It instantiates a sort-merge based strategy to find joining pairs of records or joins records with null if no match is found.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.runtime.operators.AbstractOuterJoinDriver
LOG, outerJoinIterator, running, taskContext
-
-
Constructor Summary
Constructors Constructor Description FullOuterJoinDriver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected JoinTaskIterator<IT1,IT2,OT>
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>
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)
-
Methods inherited from class org.apache.flink.runtime.operators.AbstractOuterJoinDriver
cancel, cleanup, getNumberOfDriverComparators, getNumberOfInputs, getStubType, prepare, run, setup
-
-
-
-
Method Detail
-
getReusingOuterJoinIterator
protected JoinTaskIterator<IT1,IT2,OT> 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) throws Exception
- Specified by:
getReusingOuterJoinIterator
in classAbstractOuterJoinDriver<IT1,IT2,OT>
- Throws:
Exception
-
getNonReusingOuterJoinIterator
protected JoinTaskIterator<IT1,IT2,OT> 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) throws Exception
- Specified by:
getNonReusingOuterJoinIterator
in classAbstractOuterJoinDriver<IT1,IT2,OT>
- Throws:
Exception
-
-