distributed.hadoop

Class AbstractHadoopJobConfig

java.lang.Object

distributed.core.DistributedJobConfig

distributed.hadoop.AbstractHadoopJobConfig

All Implemented Interfaces:

java.io.Serializable, OptionHandler

Direct Known Subclasses:

HDFSConfig, MapReduceJobConfig

public abstract class AbstractHadoopJobConfig
extends distributed.core.DistributedJobConfig

Base job config for Hadoop-related jobs to extend

Version:

$Revision: 13451 $

Author:

Mark Hall (mhall{[at]}pentaho{[dot]}com)

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_HOST Default jobtracker host
static java.lang.String	DEFAULT_PORT Default jobtracker port
static java.lang.String	DEFAULT_PORT_YARN Default resource manager port under YARN
static java.lang.String	JOBTRACKER_HOST Key for job tracker host name
static java.lang.String	JOBTRACKER_PORT Key for job tracker port

Constructor Summary

Constructors

Constructor and Description
AbstractHadoopJobConfig()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getJobTrackerHost() Get the job tracker host name to use
java.lang.String	getJobTrackerPort() Get the port that the job tracker is running on
static boolean	isHadoop2() Returns true if we are running against Hadoop2/Yarn
java.lang.String	jobTrackerHostTipText() Get the tool tip text for this property
java.lang.String	jobTrackerPortTipText() Get the tool tip text for this property
void	setJobTrackerHost(java.lang.String host) Set the job tracker host name to use
void	setJobTrackerPort(java.lang.String port) Set the port that the job tracker is running on

Methods inherited from class distributed.core.DistributedJobConfig

clearUserSuppliedProperties, getOptions, getProperty, getPropertyNames, getUserSuppliedProperties, getUserSuppliedProperty, getUserSuppliedPropertyNames, isEmpty, listOptions, setOptions, setProperty, setUserSuppliedProperty

Methods inherited from class java.lang.Object

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

Field Detail

JOBTRACKER_HOST

public static final java.lang.String JOBTRACKER_HOST

Key for job tracker host name

See Also:

Constant Field Values

JOBTRACKER_PORT

public static final java.lang.String JOBTRACKER_PORT

Key for job tracker port

See Also:

Constant Field Values

DEFAULT_HOST

public static final java.lang.String DEFAULT_HOST

Default jobtracker host

See Also:

Constant Field Values

DEFAULT_PORT

public static final java.lang.String DEFAULT_PORT

Default jobtracker port

See Also:

Constant Field Values

DEFAULT_PORT_YARN

public static final java.lang.String DEFAULT_PORT_YARN

Default resource manager port under YARN

See Also:

Constant Field Values

Constructor Detail

AbstractHadoopJobConfig

public AbstractHadoopJobConfig()

Method Detail

isHadoop2

public static boolean isHadoop2()

Returns true if we are running against Hadoop2/Yarn

Returns:

true if we are running against Hadoop2/Yarn

jobTrackerHostTipText

public java.lang.String jobTrackerHostTipText()

Get the tool tip text for this property

Returns:

the tool tip text for this property

setJobTrackerHost

public void setJobTrackerHost(java.lang.String host)

Set the job tracker host name to use

Parameters:

host - the name of the host the job tracker is running on

getJobTrackerHost

public java.lang.String getJobTrackerHost()

Get the job tracker host name to use

Returns:

the name of the host the job tracker is running on

jobTrackerPortTipText

public java.lang.String jobTrackerPortTipText()

Get the tool tip text for this property

Returns:

the tool tip text for this property

setJobTrackerPort

public void setJobTrackerPort(java.lang.String port)

Set the port that the job tracker is running on

Parameters:

port - the port that the job tracker is running on

getJobTrackerPort

public java.lang.String getJobTrackerPort()

Get the port that the job tracker is running on

Returns:

the port that the job tracker is running on