Run fetcher. @param batchId batchId (obtained from Generator) or null to fetch all generated fetchlists @param threads number of threads per map task @param shouldResume @param numTasks number of fetching tasks (reducers). If set to < 1 then use the d
(String batchId, int threads, boolean shouldResume,
int numTasks)
| 253 | * @throws Exception |
| 254 | */ |
| 255 | public int fetch(String batchId, int threads, boolean shouldResume, |
| 256 | int numTasks) throws Exception { |
| 257 | return fetch(batchId, threads, shouldResume, numTasks, false, false); |
| 258 | } |
| 259 | |
| 260 | /** |
| 261 | * Run fetcher. |