Package | Description |
---|---|
org.apache.accumulo.core.client | |
org.apache.accumulo.core.client.mapred | |
org.apache.accumulo.core.client.mapreduce | |
org.apache.accumulo.minicluster |
Modifier and Type | Method and Description |
---|---|
static ClientConfiguration |
ClientConfiguration.deserialize(String serializedConfig) |
static ClientConfiguration |
ClientConfiguration.loadDefault()
Attempts to load a configuration file from the system using the default search paths.
|
ClientConfiguration |
ClientConfiguration.with(ClientConfiguration.ClientProperty prop,
String value)
Same as
setProperty(ClientProperty, String) but returns the ClientConfiguration for chaining purposes |
ClientConfiguration |
ClientConfiguration.withInstance(String instanceName)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_NAME |
ClientConfiguration |
ClientConfiguration.withInstance(UUID instanceId)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_ID |
ClientConfiguration |
ClientConfiguration.withKeystore(String path)
Same as
withKeystore(String, String, String) with password null and type null |
ClientConfiguration |
ClientConfiguration.withKeystore(String path,
String password,
String type)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_RPC_SSL_CLIENT_AUTH, ClientProperty.RPC_SSL_KEYSTORE_PATH,
ClientProperty.RPC_SSL_KEYSTORE_PASSWORD, and ClientProperty.RPC_SSL_KEYSTORE_TYPE |
ClientConfiguration |
ClientConfiguration.withSasl(boolean saslEnabled)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_RPC_SASL_ENABLED. |
ClientConfiguration |
ClientConfiguration.withSasl(boolean saslEnabled,
String kerberosServerPrimary)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_RPC_SASL_ENABLED and ClientProperty.GENERAL_KERBEROS_PRINCIPAL. |
ClientConfiguration |
ClientConfiguration.withSsl(boolean sslEnabled)
Same as
withSsl(boolean, boolean) with useJsseConfig set to false |
ClientConfiguration |
ClientConfiguration.withSsl(boolean sslEnabled,
boolean useJsseConfig)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_RPC_SSL_ENABLED and ClientProperty.RPC_USE_JSSE |
ClientConfiguration |
ClientConfiguration.withTruststore(String path)
Same as
withTruststore(String) with password null and type null |
ClientConfiguration |
ClientConfiguration.withTruststore(String path,
String password,
String type)
Same as
with(ClientProperty, String) for ClientProperty.RPC_SSL_TRUSTORE_PATH, ClientProperty.RPC_SSL_TRUSTORE_PASSWORD, and
ClientProperty.RPC_SSL_TRUSTORE_TYPE |
ClientConfiguration |
ClientConfiguration.withZkHosts(String zooKeepers)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_ZK_HOST |
ClientConfiguration |
ClientConfiguration.withZkTimeout(int timeout)
Same as
with(ClientProperty, String) for ClientProperty.INSTANCE_ZK_TIMEOUT |
Modifier and Type | Method and Description |
---|---|
protected static ClientConfiguration |
AbstractInputFormat.getClientConfiguration(org.apache.hadoop.mapred.JobConf job)
Fetch the client configuration from the job.
|
Modifier and Type | Method and Description |
---|---|
static void |
AbstractInputFormat.setZooKeeperInstance(org.apache.hadoop.mapred.JobConf job,
ClientConfiguration clientConfig)
Configures a
ZooKeeperInstance for this job. |
static void |
AccumuloOutputFormat.setZooKeeperInstance(org.apache.hadoop.mapred.JobConf job,
ClientConfiguration clientConfig)
Configures a
ZooKeeperInstance for this job. |
Modifier and Type | Method and Description |
---|---|
protected static ClientConfiguration |
AbstractInputFormat.getClientConfiguration(org.apache.hadoop.mapreduce.JobContext context)
Construct the
ClientConfiguration given the provided context. |
Modifier and Type | Method and Description |
---|---|
Instance |
RangeInputSplit.getInstance(ClientConfiguration base) |
static void |
AbstractInputFormat.setZooKeeperInstance(org.apache.hadoop.mapreduce.Job job,
ClientConfiguration clientConfig)
Configures a
ZooKeeperInstance for this job. |
static void |
AccumuloOutputFormat.setZooKeeperInstance(org.apache.hadoop.mapreduce.Job job,
ClientConfiguration clientConfig)
Configures a
ZooKeeperInstance for this job. |
Modifier and Type | Method and Description |
---|---|
ClientConfiguration |
MiniAccumuloCluster.getClientConfig() |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.