org.apache.hadoop.mapreduce

Class Cluster

java.lang.Object

org.apache.hadoop.mapreduce.Cluster

public class Cluster
extends java.lang.Object

Provides a way to access information about the map/reduce cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Cluster.JobTrackerStatus

Constructor Summary

Constructors

Constructor and Description
Cluster(org.apache.hadoop.conf.Configuration conf)
Cluster(java.net.InetSocketAddress jobTrackAddr, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.fs.Path	getStagingAreaDir() Grab the jobtracker's view of the staging directory path where job-specific files will be placed.

Methods inherited from class java.lang.Object

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

Constructor Detail

Cluster

public Cluster(org.apache.hadoop.conf.Configuration conf)
        throws java.io.IOException

Throws:

java.io.IOException

Cluster

public Cluster(java.net.InetSocketAddress jobTrackAddr,
       org.apache.hadoop.conf.Configuration conf)
        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getStagingAreaDir

public org.apache.hadoop.fs.Path getStagingAreaDir()
                                            throws java.io.IOException,
                                                   java.lang.InterruptedException

Grab the jobtracker's view of the staging directory path where job-specific files will be placed.

Returns:

the staging directory where job-specific files are to be placed.

Throws:

java.io.IOException

java.lang.InterruptedException