org.apache.oozie.action.hadoop
Class LauncherMapperHelper

java.lang.Object
  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)