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());
  }
}

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, getName(), getConf());
  }
}

Support naming the Crunch pipelines.
Support naming the Crunch pipelines.
