Uses of Interface
com.google.appengine.tools.mapreduce.impl.shardedjob.IncrementalTask

Packages that use IncrementalTask

Package	Description
com.google.appengine.tools.mapreduce.impl
com.google.appengine.tools.mapreduce.impl.pipeline
com.google.appengine.tools.mapreduce.impl.shardedjob
com.google.appengine.tools.mapreduce.impl.sort

Uses of IncrementalTask in com.google.appengine.tools.mapreduce.impl

Subinterfaces of IncrementalTask in com.google.appengine.tools.mapreduce.impl

Modifier and Type	Interface and Description
interface	IncrementalTaskWithContext A simple extension of IncrementalTask to add information for display in a UI.

Classes in com.google.appengine.tools.mapreduce.impl that implement IncrementalTask

Modifier and Type	Class and Description
class	MapOnlyShardTask<I,O>
class	MapShardTask<I,K,V>
class	ReduceShardTask<K,V,O>
class	WorkerShardTask<I,O,C extends WorkerContext<O>> Base class for the specific MR stage workers.

Uses of IncrementalTask in com.google.appengine.tools.mapreduce.impl.pipeline

Classes in com.google.appengine.tools.mapreduce.impl.pipeline with type parameters of type IncrementalTask

Modifier and Type	Class and Description
class	ShardedJob<T extends IncrementalTask> ShardedJob pipeline.

Uses of IncrementalTask in com.google.appengine.tools.mapreduce.impl.shardedjob

Classes in com.google.appengine.tools.mapreduce.impl.shardedjob with type parameters of type IncrementalTask

Modifier and Type	Class and Description
class	IncrementalTaskState<T extends IncrementalTask> Information about execution of an IncrementalTask.
class	ShardedJobController<T extends IncrementalTask> Aggregates results from IncrementalTasks and receives notification when the job completes.
class	ShardedJobRunner<T extends IncrementalTask> Contains all logic to manage and run sharded jobs.
class	ShardRetryState<T extends IncrementalTask> Retry information for a shard.

Methods in com.google.appengine.tools.mapreduce.impl.shardedjob with type parameters of type IncrementalTask

Modifier and Type	Method and Description
static <T extends IncrementalTask> IncrementalTaskState<T>	IncrementalTaskState.Serializer.fromEntity(com.google.appengine.api.datastore.Entity in, boolean lenient)
static <T extends IncrementalTask> void	InProcessShardedJobRunner.runJob(List<T> initialTasks, ShardedJobController<T> controller) Runs the given job and returns its result.
<T extends IncrementalTask> void	ShardedJobService.startJob(String jobId, List<? extends T> initialTasks, ShardedJobController<T> controller, ShardedJobSettings settings) Starts a new sharded job with the given ID and parameters.

Methods in com.google.appengine.tools.mapreduce.impl.shardedjob that return types with arguments of type IncrementalTask

Modifier and Type	Method and Description
Iterator<IncrementalTaskState<IncrementalTask>>	ShardedJobService.lookupTasks(ShardedJobState state) Returns the tasks associated with this ShardedJob.

Uses of IncrementalTask in com.google.appengine.tools.mapreduce.impl.sort

Classes in com.google.appengine.tools.mapreduce.impl.sort that implement IncrementalTask

Modifier and Type	Class and Description
class	MergeShardTask Passes input to the output.
class	SortShardTask Keeps accepting inputs and passing them to a SortWorker until the worker's buffer is full.