|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.accumulo.core.client.mapreduce.lib.util.ConfiguratorBase
public class ConfiguratorBase
Nested Class Summary | |
---|---|
static class |
ConfiguratorBase.ConnectorInfo
Configuration keys for Instance.getConnector(String, byte[]) . |
protected static class |
ConfiguratorBase.GeneralOpts
Configuration keys for general configuration options. |
protected static class |
ConfiguratorBase.InstanceOpts
Configuration keys for Instance , ZooKeeperInstance , and MockInstance . |
Constructor Summary | |
---|---|
ConfiguratorBase()
|
Method Summary | |
---|---|
protected static String |
enumToConfKey(Class<?> implementingClass,
Enum<?> e)
Provides a configuration key for a given feature enum, prefixed by the implementingClass |
static Instance |
getInstance(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Initializes an Accumulo Instance based on the configuration. |
static org.apache.log4j.Level |
getLogLevel(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Gets the log level from this configuration. |
static String |
getPrincipal(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Gets the user name from the configuration. |
static byte[] |
getToken(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Gets the password from the configuration. |
static String |
getTokenClass(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Gets the serialized token class from the configuration. |
static Boolean |
isConnectorInfoSet(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Determines if the connector info has already been set for this instance. |
static void |
setConnectorInfo(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
String principal,
AuthenticationToken token)
Sets the connector information needed to communicate with Accumulo in this job. |
static void |
setLogLevel(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
org.apache.log4j.Level level)
Sets the log level for this job. |
static void |
setMockInstance(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
String instanceName)
Configures a MockInstance for this job. |
static void |
setZooKeeperInstance(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
String instanceName,
String zooKeepers)
Configures a ZooKeeperInstance for this job. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ConfiguratorBase()
Method Detail |
---|
protected static String enumToConfKey(Class<?> implementingClass, Enum<?> e)
implementingClass
- the class whose name will be used as a prefix for the property configuration keye
- the enum used to provide the unique part of the configuration key
public static void setConnectorInfo(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, String principal, AuthenticationToken token) throws AccumuloSecurityException
WARNING: The serialized token is stored in the configuration and shared with all MapReduce tasks. It is BASE64 encoded to provide a charset safe conversion to a string, and is not intended to be secure.
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configureprincipal
- a valid Accumulo user nametoken
- the user's password
AccumuloSecurityException
public static Boolean isConnectorInfoSet(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configure
setConnectorInfo(Class, Configuration, String, AuthenticationToken)
public static String getPrincipal(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configure
setConnectorInfo(Class, Configuration, String, AuthenticationToken)
public static String getTokenClass(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configure
setConnectorInfo(Class, Configuration, String, AuthenticationToken)
public static byte[] getToken(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configure
setConnectorInfo(Class, Configuration, String, AuthenticationToken)
public static void setZooKeeperInstance(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, String instanceName, String zooKeepers)
ZooKeeperInstance
for this job.
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configureinstanceName
- the Accumulo instance namezooKeepers
- a comma-separated list of zookeeper serverspublic static void setMockInstance(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, String instanceName)
MockInstance
for this job.
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configureinstanceName
- the Accumulo instance namepublic static Instance getInstance(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
Instance
based on the configuration.
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configure
setZooKeeperInstance(Class, Configuration, String, String)
,
setMockInstance(Class, Configuration, String)
public static void setLogLevel(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, org.apache.log4j.Level level)
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configurelevel
- the logging levelpublic static org.apache.log4j.Level getLogLevel(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
implementingClass
- the class whose name will be used as a prefix for the property configuration keyconf
- the Hadoop configuration object to configure
setLogLevel(Class, Configuration, Level)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |