org.apache.hcatalog.templeton
Class AppConfig

Object
  Configuration
      AppConfig

All Implemented Interfaces:

Iterable<Map.Entry<String,String>>, Writable

public class AppConfig
extends Configuration

The configuration for Templeton. This merges the normal Hadoop configuration with the Templeton specific variables. The Templeton configuration variables are described in templeton-default.xml The Templeton specific configuration is split into two layers 1. webhcat-default.xml - All the configuration variables that Templeton needs. These are the defaults that ship with the app and should only be changed be the app developers. 2. webhcat-site.xml - The (possibly empty) configuration that the system administrator can set variables for their Hadoop cluster. The configuration files are loaded in this order with later files overriding earlier ones. To find the configuration files, we first attempt to load a file from the CLASSPATH and then look in the directory specified in the TEMPLETON_HOME environment variable. In addition the configuration files may access the special env variable env for all environment variables. For example, the hadoop executable could be specified using:

      ${env.HADOOP_PREFIX}/bin/hadoop

Nested Class Summary

Nested classes/interfaces inherited from class Configuration

Configuration.IntegerRanges

Field Summary

static String	CALLBACK_INTERVAL_NAME
static String	CALLBACK_RETRY_NAME
static String	EXEC_ENCODING_NAME
static String	EXEC_ENVS_NAME
static String	EXEC_MAX_BYTES_NAME
static String	EXEC_MAX_PROCS_NAME
static String	EXEC_TIMEOUT_NAME
static String	HADOOP_CHILD_JAVA_OPTS
static String	HADOOP_CONF_DIR
static String[]	HADOOP_CONF_FILENAMES
static String	HADOOP_END_INTERVAL_NAME
static String	HADOOP_END_RETRY_NAME
static String	HADOOP_END_URL_NAME
static String	HADOOP_NAME
static String[]	HADOOP_PREFIX_VARS
static String	HADOOP_SPECULATIVE_NAME
static String	HCAT_NAME
static String	HIVE_ARCHIVE_NAME
static String	HIVE_PATH_NAME
static String	HIVE_PROPS_NAME
static String	KERBEROS_KEYTAB
static String	KERBEROS_PRINCIPAL
static String	KERBEROS_SECRET
static String	LIB_JARS_NAME
static String	OVERRIDE_JARS_ENABLED
static String	OVERRIDE_JARS_NAME
static String	PIG_ARCHIVE_NAME
static String	PIG_PATH_NAME
static String	PORT
static String	STREAMING_JAR_NAME
static String[]	TEMPLETON_CONF_FILENAMES
static String	TEMPLETON_CONTROLLER_MR_CHILD_OPTS
static String	TEMPLETON_HOME_VAR
static String	TEMPLETON_JAR_NAME

Constructor Summary

AppConfig()

Method Summary

String	clusterHadoop()
String	clusterHcat()
String	controllerMRChildOpts()
String	getHadoopConfDir()
static String	getTempletonDir()
String	hiveArchive()
String	hivePath()
String	kerberosKeytab()
String	kerberosPrincipal()
String	kerberosSecret()
String	libJars()
String[]	overrideJars()
String	overrideJarsString()
String	pigArchive()
String	pigPath()
void	startCleanup()
String	streamingJar()
String	templetonJar()
long	zkCleanupInterval()
String	zkHosts()
long	zkMaxAge()
int	zkSessionTimeout()

Methods inherited from class Configuration

addDefaultResource, addResource, addResource, addResource, addResource, clear, dumpConfiguration, get, get, getBoolean, getClass, getClass, getClassByName, getClasses, getClassLoader, getConfResourceAsInputStream, getConfResourceAsReader, getEnum, getFile, getFloat, getInstances, getInt, getLocalPath, getLong, getRange, getRaw, getResource, getStringCollection, getStrings, getStrings, getValByRegex, iterator, main, readFields, reloadConfiguration, set, setBoolean, setBooleanIfUnset, setClass, setClassLoader, setEnum, setFloat, setIfUnset, setInt, setLong, setQuietMode, setStrings, size, toString, write, writeXml

Methods inherited from class Object

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

Field Detail

HADOOP_CONF_FILENAMES

public static final String[] HADOOP_CONF_FILENAMES

HADOOP_PREFIX_VARS

public static final String[] HADOOP_PREFIX_VARS

TEMPLETON_HOME_VAR

public static final String TEMPLETON_HOME_VAR

See Also:

Constant Field Values

TEMPLETON_CONF_FILENAMES

public static final String[] TEMPLETON_CONF_FILENAMES

PORT

public static final String PORT

See Also:

Constant Field Values

EXEC_ENCODING_NAME

public static final String EXEC_ENCODING_NAME

See Also:

Constant Field Values

EXEC_ENVS_NAME

public static final String EXEC_ENVS_NAME

See Also:

Constant Field Values

EXEC_MAX_BYTES_NAME

public static final String EXEC_MAX_BYTES_NAME

See Also:

Constant Field Values

EXEC_MAX_PROCS_NAME

public static final String EXEC_MAX_PROCS_NAME

See Also:

Constant Field Values

EXEC_TIMEOUT_NAME

public static final String EXEC_TIMEOUT_NAME

See Also:

Constant Field Values

HADOOP_NAME

public static final String HADOOP_NAME

See Also:

Constant Field Values

HADOOP_CONF_DIR

public static final String HADOOP_CONF_DIR

See Also:

Constant Field Values

HCAT_NAME

public static final String HCAT_NAME

See Also:

Constant Field Values

HIVE_ARCHIVE_NAME

public static final String HIVE_ARCHIVE_NAME

See Also:

Constant Field Values

HIVE_PATH_NAME

public static final String HIVE_PATH_NAME

See Also:

Constant Field Values

HIVE_PROPS_NAME

public static final String HIVE_PROPS_NAME

See Also:

Constant Field Values

LIB_JARS_NAME

public static final String LIB_JARS_NAME

See Also:

Constant Field Values

PIG_ARCHIVE_NAME

public static final String PIG_ARCHIVE_NAME

See Also:

Constant Field Values

PIG_PATH_NAME

public static final String PIG_PATH_NAME

See Also:

Constant Field Values

STREAMING_JAR_NAME

public static final String STREAMING_JAR_NAME

See Also:

Constant Field Values

TEMPLETON_JAR_NAME

public static final String TEMPLETON_JAR_NAME

See Also:

Constant Field Values

OVERRIDE_JARS_NAME

public static final String OVERRIDE_JARS_NAME

See Also:

Constant Field Values

OVERRIDE_JARS_ENABLED

public static final String OVERRIDE_JARS_ENABLED

See Also:

Constant Field Values

TEMPLETON_CONTROLLER_MR_CHILD_OPTS

public static final String TEMPLETON_CONTROLLER_MR_CHILD_OPTS

See Also:

Constant Field Values

KERBEROS_SECRET

public static final String KERBEROS_SECRET

See Also:

Constant Field Values

KERBEROS_PRINCIPAL

public static final String KERBEROS_PRINCIPAL

See Also:

Constant Field Values

KERBEROS_KEYTAB

public static final String KERBEROS_KEYTAB

See Also:

Constant Field Values

CALLBACK_INTERVAL_NAME

public static final String CALLBACK_INTERVAL_NAME

See Also:

Constant Field Values

CALLBACK_RETRY_NAME

public static final String CALLBACK_RETRY_NAME

See Also:

Constant Field Values

HADOOP_END_INTERVAL_NAME

public static final String HADOOP_END_INTERVAL_NAME

See Also:

Constant Field Values

HADOOP_END_RETRY_NAME

public static final String HADOOP_END_RETRY_NAME

See Also:

Constant Field Values

HADOOP_END_URL_NAME

public static final String HADOOP_END_URL_NAME

See Also:

Constant Field Values

HADOOP_SPECULATIVE_NAME

public static final String HADOOP_SPECULATIVE_NAME

See Also:

Constant Field Values

HADOOP_CHILD_JAVA_OPTS

public static final String HADOOP_CHILD_JAVA_OPTS

See Also:

Constant Field Values

Constructor Detail

AppConfig

public AppConfig()

Method Detail

startCleanup

public void startCleanup()

getHadoopConfDir

public String getHadoopConfDir()

getTempletonDir

public static String getTempletonDir()

templetonJar

public String templetonJar()

libJars

public String libJars()

clusterHadoop

public String clusterHadoop()

clusterHcat

public String clusterHcat()

pigPath

public String pigPath()

pigArchive

public String pigArchive()

hivePath

public String hivePath()

hiveArchive

public String hiveArchive()

streamingJar

public String streamingJar()

kerberosSecret

public String kerberosSecret()

kerberosPrincipal

public String kerberosPrincipal()

kerberosKeytab

public String kerberosKeytab()

controllerMRChildOpts

public String controllerMRChildOpts()

overrideJars

public String[] overrideJars()

overrideJarsString

public String overrideJarsString()

zkCleanupInterval

public long zkCleanupInterval()

zkMaxAge

public long zkMaxAge()

zkHosts

public String zkHosts()

zkSessionTimeout

public int zkSessionTimeout()