Package com.google.appengine.tools.mapreduce.impl.pipeline

Class Summary

Class	Description
CleanupPipelineJob	A pipeline to delete MR result with a FilesByShard and removing its traces when completed (therefore should be called as a new pipeline via the CleanupPipelineJob.cleanup(java.util.List<com.google.appengine.tools.cloudstorage.GcsFilename>, com.google.appengine.tools.pipeline.JobSetting...) method).
DeleteFilesJob	A job which deletes all the files in the provided GoogleCloudStorageFileSet
ExamineStatusAndReturnResult<R>	A pipeline job that examines ResultAndStatus and returns MapReduceResult when status is DONE or throw a MapReduceJobException otherwise.
ResultAndStatus<R>	A holder for MR result and its status.
ShardedJob<T extends IncrementalTask>	ShardedJob pipeline.