org.apache.oozie.action.hadoop
Class LauncherMapperHelper

java.lang.Object
  extended by org.apache.oozie.action.hadoop.LauncherMapperHelper

public class LauncherMapperHelper
extends Object


Constructor Summary
LauncherMapperHelper()
           
 
Method Summary
static org.apache.hadoop.fs.Path getActionStatsDataPath(org.apache.hadoop.fs.Path actionDir)
          Get the location of stats file
static org.apache.hadoop.fs.Path getErrorPath(org.apache.hadoop.fs.Path actionDir)
           
static org.apache.hadoop.fs.Path getExternalChildIDsDataPath(org.apache.hadoop.fs.Path actionDir)
          Get the location of external Child IDs file
static org.apache.hadoop.fs.Path getIdSwapPath(org.apache.hadoop.fs.Path actionDir)
           
static org.apache.hadoop.fs.Path getOutputDataPath(org.apache.hadoop.fs.Path actionDir)
           
static String getRecoveryId(org.apache.hadoop.conf.Configuration launcherConf, org.apache.hadoop.fs.Path actionDir, String recoveryId)
           
static boolean hasIdSwap(org.apache.hadoop.mapred.RunningJob runningJob)
           
static boolean hasIdSwap(org.apache.hadoop.mapred.RunningJob runningJob, String user, String group, org.apache.hadoop.fs.Path actionDir)
           
static boolean hasOutputData(org.apache.hadoop.mapred.RunningJob runningJob)
           
static boolean hasStatsData(org.apache.hadoop.mapred.RunningJob runningJob)
          Check whether runningJob has stats data or not
static boolean isMainDone(org.apache.hadoop.mapred.RunningJob runningJob)
           
static boolean isMainSuccessful(org.apache.hadoop.mapred.RunningJob runningJob)
           
static void setupLauncherInfo(org.apache.hadoop.mapred.JobConf launcherConf, String jobId, String actionId, org.apache.hadoop.fs.Path actionDir, String recoveryId, org.apache.hadoop.conf.Configuration actionConf, String prepareXML)
           
static void setupLauncherURIHandlerConf(org.apache.hadoop.conf.Configuration launcherConf)
           
static void setupMainArguments(org.apache.hadoop.conf.Configuration launcherConf, String[] args)
           
static void setupMainClass(org.apache.hadoop.conf.Configuration launcherConf, String javaMainClass)
           
static void setupMaxExternalStatsSize(org.apache.hadoop.conf.Configuration launcherConf, int maxStatsData)
          Set the maximum value of stats data
static void setupMaxOutputData(org.apache.hadoop.conf.Configuration launcherConf, int maxOutputData)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LauncherMapperHelper

public LauncherMapperHelper()
Method Detail

getRecoveryId

public static String getRecoveryId(org.apache.hadoop.conf.Configuration launcherConf,
                                   org.apache.hadoop.fs.Path actionDir,
                                   String recoveryId)
                            throws HadoopAccessorException,
                                   IOException
Throws:
HadoopAccessorException
IOException

setupMainClass

public static void setupMainClass(org.apache.hadoop.conf.Configuration launcherConf,
                                  String javaMainClass)

setupLauncherURIHandlerConf

public static void setupLauncherURIHandlerConf(org.apache.hadoop.conf.Configuration launcherConf)

setupMainArguments

public static void setupMainArguments(org.apache.hadoop.conf.Configuration launcherConf,
                                      String[] args)

setupMaxOutputData

public static void setupMaxOutputData(org.apache.hadoop.conf.Configuration launcherConf,
                                      int maxOutputData)

setupMaxExternalStatsSize

public static void setupMaxExternalStatsSize(org.apache.hadoop.conf.Configuration launcherConf,
                                             int maxStatsData)
Set the maximum value of stats data

Parameters:
launcherConf - the oozie launcher configuration
maxStatsData - the maximum allowed size of stats data

setupLauncherInfo

public static void setupLauncherInfo(org.apache.hadoop.mapred.JobConf launcherConf,
                                     String jobId,
                                     String actionId,
                                     org.apache.hadoop.fs.Path actionDir,
                                     String recoveryId,
                                     org.apache.hadoop.conf.Configuration actionConf,
                                     String prepareXML)
                              throws IOException,
                                     HadoopAccessorException
Throws:
IOException
HadoopAccessorException

isMainDone

public static boolean isMainDone(org.apache.hadoop.mapred.RunningJob runningJob)
                          throws IOException
Throws:
IOException

isMainSuccessful

public static boolean isMainSuccessful(org.apache.hadoop.mapred.RunningJob runningJob)
                                throws IOException
Throws:
IOException

hasOutputData

public static boolean hasOutputData(org.apache.hadoop.mapred.RunningJob runningJob)
                             throws IOException
Throws:
IOException

hasStatsData

public static boolean hasStatsData(org.apache.hadoop.mapred.RunningJob runningJob)
                            throws IOException
Check whether runningJob has stats data or not

Parameters:
runningJob - the runningJob
Returns:
returns whether the running Job has stats data or not
Throws:
IOException

hasIdSwap

public static boolean hasIdSwap(org.apache.hadoop.mapred.RunningJob runningJob)
                         throws IOException
Throws:
IOException

hasIdSwap

public static boolean hasIdSwap(org.apache.hadoop.mapred.RunningJob runningJob,
                                String user,
                                String group,
                                org.apache.hadoop.fs.Path actionDir)
                         throws IOException,
                                HadoopAccessorException
Throws:
IOException
HadoopAccessorException

getOutputDataPath

public static org.apache.hadoop.fs.Path getOutputDataPath(org.apache.hadoop.fs.Path actionDir)

getActionStatsDataPath

public static org.apache.hadoop.fs.Path getActionStatsDataPath(org.apache.hadoop.fs.Path actionDir)
Get the location of stats file

Parameters:
actionDir - the action directory
Returns:
the hdfs location of the file

getExternalChildIDsDataPath

public static org.apache.hadoop.fs.Path getExternalChildIDsDataPath(org.apache.hadoop.fs.Path actionDir)
Get the location of external Child IDs file

Parameters:
actionDir - the action directory
Returns:
the hdfs location of the file

getErrorPath

public static org.apache.hadoop.fs.Path getErrorPath(org.apache.hadoop.fs.Path actionDir)

getIdSwapPath

public static org.apache.hadoop.fs.Path getIdSwapPath(org.apache.hadoop.fs.Path actionDir)


Copyright © 2013 Apache Software Foundation. All Rights Reserved.