public class AccumuloConnectionParameters extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
static String |
INSTANCE_NAME |
static String |
SASL_ENABLED |
static String |
TABLE_NAME |
static String |
USE_MOCK_INSTANCE |
protected boolean |
useMockInstance |
static String |
USER_KEYTAB |
static String |
USER_NAME |
static String |
USER_PASS |
static String |
ZOOKEEPERS |
Constructor and Description |
---|
AccumuloConnectionParameters(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
String |
getAccumuloInstanceName() |
String |
getAccumuloKeytab() |
String |
getAccumuloPassword() |
String |
getAccumuloTableName() |
String |
getAccumuloUserName() |
org.apache.hadoop.conf.Configuration |
getConf() |
org.apache.accumulo.core.client.Connector |
getConnector() |
org.apache.accumulo.core.client.Connector |
getConnector(org.apache.accumulo.core.client.Instance inst) |
org.apache.accumulo.core.client.Instance |
getInstance() |
org.apache.accumulo.core.client.security.tokens.AuthenticationToken |
getKerberosToken() |
String |
getZooKeepers() |
boolean |
useMockInstance() |
boolean |
useSasl() |
public static final String USER_NAME
public static final String USER_PASS
public static final String ZOOKEEPERS
public static final String INSTANCE_NAME
public static final String TABLE_NAME
public static final String SASL_ENABLED
public static final String USER_KEYTAB
public static final String USE_MOCK_INSTANCE
protected org.apache.hadoop.conf.Configuration conf
protected boolean useMockInstance
public AccumuloConnectionParameters(org.apache.hadoop.conf.Configuration conf)
public org.apache.hadoop.conf.Configuration getConf()
public String getAccumuloUserName()
public String getAccumuloPassword()
public String getAccumuloInstanceName()
public String getZooKeepers()
public String getAccumuloTableName()
public boolean useMockInstance()
public boolean useSasl()
public String getAccumuloKeytab()
public org.apache.accumulo.core.client.Instance getInstance()
public org.apache.accumulo.core.client.Connector getConnector() throws org.apache.accumulo.core.client.AccumuloException, org.apache.accumulo.core.client.AccumuloSecurityException
org.apache.accumulo.core.client.AccumuloException
org.apache.accumulo.core.client.AccumuloSecurityException
public org.apache.accumulo.core.client.Connector getConnector(org.apache.accumulo.core.client.Instance inst) throws org.apache.accumulo.core.client.AccumuloException, org.apache.accumulo.core.client.AccumuloSecurityException
org.apache.accumulo.core.client.AccumuloException
org.apache.accumulo.core.client.AccumuloSecurityException
public org.apache.accumulo.core.client.security.tokens.AuthenticationToken getKerberosToken()
Copyright © 2017 The Apache Software Foundation. All rights reserved.