|
Class Summary |
| FetchContext |
A dummy counter handling context for fetch tasks |
| FetchLauncher |
This class is responsible for executing the fetch task, saving the result to disk
and do the necessary cleanup afterwards. |
| FetchOptimizer |
FetchOptimizer determines whether the entire physical plan is fetchable, meaning
that the task's result can be directly read (fetched) from the underlying storage
rather than creating MR jobs. |
| FetchPOStoreImpl |
This class is used to have a POStore write the output to the underlying storage
via a output collector/record writer in case of a fetch task. |
| FetchProgressableReporter |
A dummy ProgressableReporter used for fetch tasks |
| FetchTaskContext |
|