| Package | Description |
|---|---|
| com.google.appengine.tools.mapreduce.impl | |
| com.google.appengine.tools.mapreduce.impl.pipeline | |
| com.google.appengine.tools.mapreduce.impl.shardedjob |
| Modifier and Type | Class and Description |
|---|---|
class |
WorkerController<I,O,R,C extends WorkerContext<O>> |
| Constructor and Description |
|---|
ShardedJob(String shardedJobId,
List<? extends T> workers,
ShardedJobController<T> controller,
ShardedJobSettings shardedJobSettings) |
| Modifier and Type | Method and Description |
|---|---|
static <T extends IncrementalTask> |
InProcessShardedJobRunner.runJob(List<T> initialTasks,
ShardedJobController<T> controller)
Runs the given job and returns its result.
|
<T extends IncrementalTask> |
ShardedJobService.startJob(String jobId,
List<? extends T> initialTasks,
ShardedJobController<T> controller,
ShardedJobSettings settings)
Starts a new sharded job with the given ID and parameters.
|
Copyright © 2015 Google. All rights reserved.