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.