package org.kitesdk.apps.crunch;

import org.kitesdk.apps.scheduled.AbstractSchedulableJob;
import org.apache.crunch.Pipeline;
import org.apache.crunch.impl.mr.MRPipeline;

/**
 * Abstract base class for Crunch-based jobs.
 */
public abstract class AbstractCrunchJob extends AbstractSchedulableJob {

  protected Pipeline getPipeline() {
    return new MRPipeline(AbstractCrunchJob.class, getConf());
  }
}

@@ -381,16 +381,27 @@
 b.class,
+ getName(),
  getConf

Support naming the Crunch pipelines.