public abstract class AbstractOuterJoinDriver<IT1,IT2,OT> extends Object implements Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
FlatJoinFunction
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
protected JoinTaskIterator<IT1,IT2,OT> |
outerJoinIterator |
protected boolean |
running |
protected TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> |
taskContext |
Constructor and Description |
---|
AbstractOuterJoinDriver() |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
This method is invoked when the driver must aborted in mid processing.
|
void |
cleanup()
This method is invoked in any case (clean termination and exception) at the end of the tasks operation.
|
protected abstract 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) |
int |
getNumberOfDriverComparators()
Gets the number of comparators required for this driver.
|
int |
getNumberOfInputs()
Gets the number of inputs that the task has.
|
protected abstract 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) |
Class<FlatJoinFunction<IT1,IT2,OT>> |
getStubType()
Gets the class of the stub type that is run by this task.
|
void |
prepare()
This method is called before the user code is opened.
|
void |
run()
The main operation method of the task.
|
void |
setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
protected static final org.slf4j.Logger LOG
protected TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> taskContext
protected volatile JoinTaskIterator<IT1,IT2,OT> outerJoinIterator
protected volatile boolean running
public void setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context)
public int getNumberOfInputs()
Driver
getNumberOfInputs
in interface Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
public Class<FlatJoinFunction<IT1,IT2,OT>> getStubType()
Driver
MapFunction.class
.getStubType
in interface Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
public int getNumberOfDriverComparators()
Driver
getNumberOfDriverComparators
in interface Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
public void prepare() throws Exception
Driver
public void run() throws Exception
Driver
run
in interface Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
Exception
- Any exception thrown by this method signals task failure. Because exceptions in the user
code typically signal situations where this instance in unable to proceed, exceptions
from the user code should be forwarded.public void cleanup() throws Exception
Driver
public void cancel()
Driver
protected abstract 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
Exception
protected abstract 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
Exception
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.