public class FullOuterJoinDriver<IT1,IT2,OT> extends AbstractOuterJoinDriver<IT1,IT2,OT>
LOG, outerJoinIterator, running, taskContext
Constructor and Description |
---|
FullOuterJoinDriver() |
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) |
cancel, cleanup, getNumberOfDriverComparators, getNumberOfInputs, getStubType, prepare, run, setup
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
getReusingOuterJoinIterator
in class AbstractOuterJoinDriver<IT1,IT2,OT>
Exception
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
getNonReusingOuterJoinIterator
in class AbstractOuterJoinDriver<IT1,IT2,OT>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.