com.atlantbh.jmeter.plugins.hadooputilities.jobstatistics

Class JobLayer

java.lang.Object

com.atlantbh.jmeter.plugins.hadooputilities.jobstatistics.JobLayer

Direct Known Subclasses:

TaskLayer

public class JobLayer
extends Object

This class exposes functionalities on Job layer. Those functionalities are: 1. getJobCountersByJobId 2. getJobCountersByJobIdAndGroupName 3. getJobStatisticsByJobId

Constructor Summary

Constructors

Constructor and Description
JobLayer()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.mapred.JobID	convertToJobId(String jobId)
String	getCountersAsXml(Map<String,String> jobCounters)
String	getGroupName()
Map<String,String>	getJobCountersByJobId(String jobTracker, String jobId)
Map<String,String>	getJobCountersByJobIdAndGroupName(String jobTracker, String jobId, String groupName)
String	getJobId()
String	getJobState()
String	getJobStatisticsByJobId(String jobTracker, String jobId)
String	getJobTracker()
protected org.apache.hadoop.mapred.JobClient	prepareJobClient(String jobTracker)
void	setGroupName(String groupName)
void	setJobId(String jobId)
void	setJobState(String jobState)
void	setJobTracker(String jobTracker)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobLayer

public JobLayer()

Method Detail

getJobId

public String getJobId()

setJobId

public void setJobId(String jobId)

getJobTracker

public String getJobTracker()

setJobTracker

public void setJobTracker(String jobTracker)

getJobState

public String getJobState()

setJobState

public void setJobState(String jobState)

getGroupName

public String getGroupName()

setGroupName

public void setGroupName(String groupName)

prepareJobClient

protected org.apache.hadoop.mapred.JobClient prepareJobClient(String jobTracker)
                                                       throws IOException

Throws:

IOException

convertToJobId

protected org.apache.hadoop.mapred.JobID convertToJobId(String jobId)

getCountersAsXml

public String getCountersAsXml(Map<String,String> jobCounters)
                        throws IOException

Throws:

IOException

getJobCountersByJobId

public Map<String,String> getJobCountersByJobId(String jobTracker,
                                                String jobId)
                                         throws IOException

Throws:

IOException

getJobCountersByJobIdAndGroupName

public Map<String,String> getJobCountersByJobIdAndGroupName(String jobTracker,
                                                            String jobId,
                                                            String groupName)
                                                     throws IOException

Throws:

IOException

getJobStatisticsByJobId

public String getJobStatisticsByJobId(String jobTracker,
                                      String jobId)
                               throws IOException

Throws:

IOException