org.apache.flink.runtime.operators

Class RightOuterJoinDriver<IT1,IT2,OT>

java.lang.Object

org.apache.flink.runtime.operators.AbstractOuterJoinDriver<IT1,IT2,OT>

org.apache.flink.runtime.operators.RightOuterJoinDriver<IT1,IT2,OT>

All Implemented Interfaces:

Driver<FlatJoinFunction<IT1,IT2,OT>,OT>

public class RightOuterJoinDriver<IT1,IT2,OT>
extends AbstractOuterJoinDriver<IT1,IT2,OT>

The right 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 from the right side 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 and Description
RightOuterJoinDriver()

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

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

Constructor Detail

RightOuterJoinDriver

public RightOuterJoinDriver()

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 class AbstractOuterJoinDriver<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 class AbstractOuterJoinDriver<IT1,IT2,OT>

Throws:

Exception