Modifier and Type | Method and Description |
---|---|
BatchWriterConfig |
BatchWriterConfig.setDurability(Durability durability)
Change the durability for the BatchWriter session.
|
BatchWriterConfig |
BatchWriterConfig.setMaxLatency(long maxLatency,
TimeUnit timeUnit)
Sets the maximum amount of time to hold the data in memory before flushing it to servers.
For no maximum, set to zero, or Long.MAX_VALUE with TimeUnit.MILLISECONDS . |
BatchWriterConfig |
BatchWriterConfig.setMaxMemory(long maxMemory)
Sets the maximum memory to batch before writing.
|
BatchWriterConfig |
BatchWriterConfig.setMaxWriteThreads(int maxWriteThreads)
Sets the maximum number of threads to use for writing data to the tablet servers.
|
BatchWriterConfig |
BatchWriterConfig.setTimeout(long timeout,
TimeUnit timeUnit)
Sets the maximum amount of time an unresponsive server will be re-tried.
|
Modifier and Type | Method and Description |
---|---|
abstract BatchDeleter |
Connector.createBatchDeleter(String tableName,
Authorizations authorizations,
int numQueryThreads,
BatchWriterConfig config) |
abstract BatchWriter |
Connector.createBatchWriter(String tableName,
BatchWriterConfig config)
Factory method to create a BatchWriter connected to Accumulo.
|
abstract MultiTableBatchWriter |
Connector.createMultiTableBatchWriter(BatchWriterConfig config)
Factory method to create a Multi-Table BatchWriter connected to Accumulo.
|
Modifier and Type | Method and Description |
---|---|
protected static BatchWriterConfig |
AccumuloOutputFormat.getBatchWriterOptions(org.apache.hadoop.mapred.JobConf job)
Gets the
BatchWriterConfig settings. |
Modifier and Type | Method and Description |
---|---|
static void |
AccumuloOutputFormat.setBatchWriterOptions(org.apache.hadoop.mapred.JobConf job,
BatchWriterConfig bwConfig)
Sets the configuration for for the job's
BatchWriter instances. |
Modifier and Type | Method and Description |
---|---|
protected static BatchWriterConfig |
AccumuloOutputFormat.getBatchWriterOptions(org.apache.hadoop.mapreduce.JobContext context)
Gets the
BatchWriterConfig settings. |
Modifier and Type | Method and Description |
---|---|
static void |
AccumuloOutputFormat.setBatchWriterOptions(org.apache.hadoop.mapreduce.Job job,
BatchWriterConfig bwConfig)
Sets the configuration for for the job's
BatchWriter instances. |
Modifier and Type | Method and Description |
---|---|
static BatchWriterConfig |
OutputConfigurator.getBatchWriterOptions(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Deprecated.
since 1.6.0; Configure your job with the appropriate InputFormat or OutputFormat.
|
Modifier and Type | Method and Description |
---|---|
static void |
OutputConfigurator.setBatchWriterOptions(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
BatchWriterConfig bwConfig)
Deprecated.
since 1.6.0; Configure your job with the appropriate InputFormat or OutputFormat.
|
Modifier and Type | Method and Description |
---|---|
BatchDeleter |
MockConnector.createBatchDeleter(String tableName,
Authorizations authorizations,
int numQueryThreads,
BatchWriterConfig config) |
BatchWriter |
MockConnector.createBatchWriter(String tableName,
BatchWriterConfig config) |
MultiTableBatchWriter |
MockConnector.createMultiTableBatchWriter(BatchWriterConfig config) |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.