Package | Description |
---|---|
org.apache.accumulo.core.client | |
org.apache.accumulo.core.client.admin | |
org.apache.accumulo.core.client.mapred | |
org.apache.accumulo.core.client.mapreduce | |
org.apache.accumulo.core.client.mapreduce.lib.util |
This package exists to store common helpers for configuring MapReduce jobs in a single location.
|
org.apache.accumulo.core.client.mock |
Modifier and Type | Method and Description |
---|---|
void |
ScannerBase.addScanIterator(IteratorSetting cfg)
Add a server-side scan iterator.
|
Modifier and Type | Method and Description |
---|---|
IteratorSetting |
TableOperationsHelper.getIteratorSetting(String tableName,
String name,
org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope scope) |
IteratorSetting |
TableOperations.getIteratorSetting(String tableName,
String name,
org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope scope)
Get the settings for an iterator.
|
Modifier and Type | Method and Description |
---|---|
List<IteratorSetting> |
ActiveCompaction.getIterators() |
Modifier and Type | Method and Description |
---|---|
void |
TableOperationsHelper.attachIterator(String tableName,
IteratorSetting setting) |
void |
TableOperations.attachIterator(String tableName,
IteratorSetting setting)
Add an iterator to a table on all scopes.
|
void |
TableOperationsImpl.attachIterator(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) |
void |
TableOperationsHelper.attachIterator(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) |
void |
TableOperations.attachIterator(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes)
Add an iterator to a table on the given scopes.
|
void |
TableOperationsHelper.checkIteratorConflicts(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) |
void |
TableOperations.checkIteratorConflicts(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes)
Check whether a given iterator configuration conflicts with existing configuration; in particular, determine if the name or priority are already in use for
the specified scopes.
|
Modifier and Type | Method and Description |
---|---|
void |
TableOperationsImpl.compact(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
List<IteratorSetting> iterators,
boolean flush,
boolean wait) |
void |
TableOperations.compact(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
List<IteratorSetting> iterators,
boolean flush,
boolean wait)
Starts a full major compaction of the tablets in the range (start, end].
|
Modifier and Type | Method and Description |
---|---|
protected static List<IteratorSetting> |
InputFormatBase.getIterators(org.apache.hadoop.mapred.JobConf job)
Gets a list of the iterator settings (for iterators to apply to a scanner) from this configuration.
|
Modifier and Type | Method and Description |
---|---|
static void |
InputFormatBase.addIterator(org.apache.hadoop.mapred.JobConf job,
IteratorSetting cfg)
Encode an iterator on the input for this job.
|
Modifier and Type | Method and Description |
---|---|
protected void |
InputFormatBase.RecordReaderBase.setupIterators(List<IteratorSetting> iterators,
Scanner scanner)
Apply the configured iterators to the scanner.
|
Modifier and Type | Method and Description |
---|---|
List<IteratorSetting> |
RangeInputSplit.getIterators() |
protected static List<IteratorSetting> |
InputFormatBase.getIterators(org.apache.hadoop.mapreduce.JobContext context)
Gets a list of the iterator settings (for iterators to apply to a scanner) from this configuration.
|
Modifier and Type | Method and Description |
---|---|
static void |
InputFormatBase.addIterator(org.apache.hadoop.conf.Configuration conf,
IteratorSetting cfg)
Deprecated.
since 1.5.0; Use
InputFormatBase.addIterator(Job, IteratorSetting) instead. |
static void |
InputFormatBase.addIterator(org.apache.hadoop.mapreduce.Job job,
IteratorSetting cfg)
Encode an iterator on the input for this job.
|
Modifier and Type | Method and Description |
---|---|
void |
RangeInputSplit.setIterators(List<IteratorSetting> iterators) |
protected void |
InputFormatBase.RecordReaderBase.setupIterators(List<IteratorSetting> iterators,
Scanner scanner)
Apply the configured iterators to the scanner.
|
Modifier and Type | Method and Description |
---|---|
static List<IteratorSetting> |
InputConfigurator.getIterators(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Gets a list of the iterator settings (for iterators to apply to a scanner) from this configuration.
|
Modifier and Type | Method and Description |
---|---|
static void |
InputConfigurator.addIterator(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
IteratorSetting cfg)
Encode an iterator on the input for this job.
|
Modifier and Type | Method and Description |
---|---|
void |
MockTableOperations.compact(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
List<IteratorSetting> iterators,
boolean flush,
boolean wait) |
Copyright © 2011-2016 The Apache Software Foundation. All Rights Reserved.