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

Class CleanupPipelineJob

java.lang.Object

com.google.appengine.tools.pipeline.Job<T>

com.google.appengine.tools.pipeline.Job1<Void,List<com.google.appengine.tools.cloudstorage.GcsFilename>>

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

All Implemented Interfaces:

Serializable

public class CleanupPipelineJob
extends com.google.appengine.tools.pipeline.Job1<Void,List<com.google.appengine.tools.cloudstorage.GcsFilename>>

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 cleanup(java.util.List<com.google.appengine.tools.cloudstorage.GcsFilename>, com.google.appengine.tools.pipeline.JobSetting...) method).

See Also:

Serialized Form

Method Summary

Methods

Modifier and Type	Method and Description
static void	cleanup(List<com.google.appengine.tools.cloudstorage.GcsFilename> toDelete, com.google.appengine.tools.pipeline.JobSetting... settings)
com.google.appengine.tools.pipeline.Value<Void>	run(List<com.google.appengine.tools.cloudstorage.GcsFilename> files)

Methods inherited from class com.google.appengine.tools.pipeline.Job

backOffFactor, backOffSeconds, futureCall, futureCall, futureCall, futureCall, futureCall, futureCall, futureCall, futureCallUnchecked, futureList, getJobDisplayName, getJobKey, getOnBackend, getOnModule, getOnQueue, getPipelineKey, getStatusConsoleUrl, immediate, maxAttempts, newDelayedValue, newPromise, newPromise, onBackend, onModule, onQueue, setStatusConsoleUrl, statusConsoleUrl, waitFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

run

public com.google.appengine.tools.pipeline.Value<Void> run(List<com.google.appengine.tools.cloudstorage.GcsFilename> files)

Specified by:

run in class com.google.appengine.tools.pipeline.Job1<Void,List<com.google.appengine.tools.cloudstorage.GcsFilename>>

cleanup

public static void cleanup(List<com.google.appengine.tools.cloudstorage.GcsFilename> toDelete,
           com.google.appengine.tools.pipeline.JobSetting... settings)