Class CoGroupWithSolutionSetSecondDriver<IT1,IT2,OT>
- java.lang.Object
-
- org.apache.flink.runtime.operators.CoGroupWithSolutionSetSecondDriver<IT1,IT2,OT>
-
- All Implemented Interfaces:
Driver<CoGroupFunction<IT1,IT2,OT>,OT>
,ResettableDriver<CoGroupFunction<IT1,IT2,OT>,OT>
public class CoGroupWithSolutionSetSecondDriver<IT1,IT2,OT> extends Object implements ResettableDriver<CoGroupFunction<IT1,IT2,OT>,OT>
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
running
-
Constructor Summary
Constructors Constructor Description CoGroupWithSolutionSetSecondDriver()
-
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.int
getNumberOfDriverComparators()
Gets the number of comparators required for this driver.int
getNumberOfInputs()
Gets the number of inputs that the task has.Class<CoGroupFunction<IT1,IT2,OT>>
getStubType()
Gets the class of the stub type that is run by this task.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
setup(TaskContext<CoGroupFunction<IT1,IT2,OT>,OT> context)
void
teardown()
-
-
-
Method Detail
-
setup
public void setup(TaskContext<CoGroupFunction<IT1,IT2,OT>,OT> context)
-
getNumberOfInputs
public int getNumberOfInputs()
Description copied from interface:Driver
Gets the number of inputs that the task has.- Specified by:
getNumberOfInputs
in interfaceDriver<IT1,IT2>
- Returns:
- The number of inputs.
-
getStubType
public Class<CoGroupFunction<IT1,IT2,OT>> getStubType()
Description copied from interface:Driver
Gets the class of the stub type that is run by this task. For example, a MapTask should returnMapFunction.class
.- Specified by:
getStubType
in interfaceDriver<IT1,IT2>
- Returns:
- The class of the stub type run by the task.
-
getNumberOfDriverComparators
public int getNumberOfDriverComparators()
Description copied from interface:Driver
Gets the number of comparators required for this driver.- Specified by:
getNumberOfDriverComparators
in interfaceDriver<IT1,IT2>
- Returns:
- The number of comparators required for this driver.
-
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()
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.
-
cleanup
public void cleanup()
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()
- Specified by:
reset
in interfaceResettableDriver<IT1,IT2>
-
teardown
public void teardown()
- Specified by:
teardown
in interfaceResettableDriver<IT1,IT2>
-
-