Package com.linkedin.venice.hadoop.mapreduce.common

Class JobUtils

java.lang.Object

com.linkedin.venice.hadoop.mapreduce.common.JobUtils

public final class JobUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static org.apache.hadoop.mapred.RunningJob	runJobWithConfig(org.apache.hadoop.mapred.JobConf jobConf, JobClientWrapper jobClientWrapper)
static void	setupCommonJobConf(VeniceProperties props, org.apache.hadoop.mapred.JobConf conf, String jobName, PushJobSetting pushJobSetting)	Common configuration for all the Mapreduce Jobs run as part of VPJ

Methods inherited from class java.lang.Object

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

Method Details

setupCommonJobConf

public static void setupCommonJobConf(VeniceProperties props,
 org.apache.hadoop.mapred.JobConf conf,
 String jobName,
 PushJobSetting pushJobSetting)

Common configuration for all the Mapreduce Jobs run as part of VPJ

Parameters:

conf -

jobName -

runJobWithConfig

public static org.apache.hadoop.mapred.RunningJob runJobWithConfig(org.apache.hadoop.mapred.JobConf jobConf,
 JobClientWrapper jobClientWrapper)
                                                            throws IOException

Throws:

IOException