Class AbstractCachedBuildSideJoinDriver<IT1,IT2,OT>
- java.lang.Object
-
- org.apache.flink.runtime.operators.JoinDriver<IT1,IT2,OT>
-
- org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver<IT1,IT2,OT>
-
- All Implemented Interfaces:
Driver<FlatJoinFunction<IT1,IT2,OT>,OT>
,ResettableDriver<FlatJoinFunction<IT1,IT2,OT>,OT>
- Direct Known Subclasses:
BuildFirstCachedJoinDriver
,BuildSecondCachedJoinDriver
public abstract class AbstractCachedBuildSideJoinDriver<IT1,IT2,OT> extends JoinDriver<IT1,IT2,OT> implements ResettableDriver<FlatJoinFunction<IT1,IT2,OT>,OT>
-
-
Field Summary
-
Fields inherited from class org.apache.flink.runtime.operators.JoinDriver
LOG, running, taskContext
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractCachedBuildSideJoinDriver(int buildSideIndex, int probeSideIndex)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.void
initialize()
boolean
isInputResettable(int inputNum)
void
prepare()
This method is called before the user code is opened.void
reset()
void
run()
The main operation method of the task.void
teardown()
-
Methods inherited from class org.apache.flink.runtime.operators.JoinDriver
getNumberOfDriverComparators, getNumberOfInputs, getStubType, setup
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.runtime.operators.Driver
getNumberOfDriverComparators, getNumberOfInputs, getStubType, setup
-
-
-
-
Method Detail
-
isInputResettable
public boolean isInputResettable(int inputNum)
- Specified by:
isInputResettable
in interfaceResettableDriver<IT1,IT2>
-
initialize
public void initialize() throws Exception
- Specified by:
initialize
in interfaceResettableDriver<IT1,IT2>
- Throws:
Exception
-
prepare
public void prepare() throws Exception
Description copied from interface:Driver
This method is called before the user code is opened. An exception thrown by this method signals failure of the task.
-
run
public void run() throws Exception
Description copied from interface:Driver
The main operation method of the task. It should call the user code with the data subsets until the input is depleted.- Specified by:
run
in interfaceDriver<IT1,IT2>
- Overrides:
run
in classJoinDriver<IT1,IT2,OT>
- Throws:
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.
-
cleanup
public void cleanup() throws Exception
Description copied from interface:Driver
This method is invoked in any case (clean termination and exception) at the end of the tasks operation.
-
reset
public void reset() throws Exception
- Specified by:
reset
in interfaceResettableDriver<IT1,IT2>
- Throws:
Exception
-
teardown
public void teardown()
- Specified by:
teardown
in interfaceResettableDriver<IT1,IT2>
-
-