S
- The type of stub driven by this driver.OT
- The data type of the records produced by this driver.public interface Driver<S extends Function,OT>
TaskContext
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.
|
int |
getNumberOfDriverComparators()
Gets the number of comparators required for this driver.
|
int |
getNumberOfInputs()
Gets the number of inputs that the task has.
|
Class<S> |
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<S,OT> context) |
void setup(TaskContext<S,OT> context)
int getNumberOfInputs()
int getNumberOfDriverComparators()
Class<S> getStubType()
MapFunction.class
.void prepare() throws Exception
Exception
- Exceptions may be forwarded and signal task failure.void run() throws Exception
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.void cleanup() throws Exception
Exception
- Exceptions may be forwarded.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.