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

Class JobUtils

  • public final class JobUtils
extends java.lang.Object

    • Method Summary

      All Methods Static Methods Concrete Methods 
      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, java.lang.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 Detail

      • setupCommonJobConf

        public static void setupCommonJobConf​(VeniceProperties props,
                                      org.apache.hadoop.mapred.JobConf conf,
                                      java.lang.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 java.io.IOException
        Throws:
        java.io.IOException