io.druid.indexer

Class JobHelper

java.lang.Object

io.druid.indexer.JobHelper

public class JobHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
JobHelper()

Method Summary

Methods

Modifier and Type	Method and Description
static void	ensurePaths(HadoopDruidIndexerConfig config)
static void	injectSystemProperties(org.apache.hadoop.mapreduce.Job job)
static boolean	runJobs(List<Jobby> jobs, HadoopDruidIndexerConfig config)
static void	setupClasspath(HadoopDruidIndexerConfig config, org.apache.hadoop.mapreduce.Job groupByJob)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobHelper

public JobHelper()

Method Detail

setupClasspath

public static void setupClasspath(HadoopDruidIndexerConfig config,
                  org.apache.hadoop.mapreduce.Job groupByJob)
                           throws IOException

Throws:

IOException

injectSystemProperties

public static void injectSystemProperties(org.apache.hadoop.mapreduce.Job job)

ensurePaths

public static void ensurePaths(HadoopDruidIndexerConfig config)

runJobs

public static boolean runJobs(List<Jobby> jobs,
              HadoopDruidIndexerConfig config)