Package | Description |
---|---|
org.apache.accumulo.core.client.mapred | |
org.apache.accumulo.core.client.mapreduce |
Modifier and Type | Method and Description |
---|---|
static InputTableConfig |
AbstractInputFormat.getInputTableConfig(org.apache.hadoop.mapred.JobConf job,
String tableName)
Fetches a
InputTableConfig that has been set on the configuration for a specific table. |
Modifier and Type | Method and Description |
---|---|
static Map<String,InputTableConfig> |
AbstractInputFormat.getInputTableConfigs(org.apache.hadoop.mapred.JobConf job)
Fetches all
InputTableConfig s that have been set on the given Hadoop job. |
Modifier and Type | Method and Description |
---|---|
static void |
AccumuloMultiTableInputFormat.setInputTableConfigs(org.apache.hadoop.mapred.JobConf job,
Map<String,InputTableConfig> configs)
Sets the
InputTableConfig objects on the given Hadoop configuration |
Modifier and Type | Method and Description |
---|---|
InputTableConfig |
InputTableConfig.fetchColumns(Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columns)
Restricts the columns that will be mapped over for this job for the default input table.
|
protected static InputTableConfig |
AbstractInputFormat.getInputTableConfig(org.apache.hadoop.mapreduce.JobContext context,
String tableName)
Fetches a
InputTableConfig that has been set on the configuration for a specific table. |
InputTableConfig |
InputTableConfig.setAutoAdjustRanges(boolean autoAdjustRanges)
Controls the automatic adjustment of ranges for this job.
|
InputTableConfig |
InputTableConfig.setIterators(List<IteratorSetting> iterators)
Set iterators on to be used in the query.
|
InputTableConfig |
InputTableConfig.setOfflineScan(boolean offlineScan)
Enable reading offline tables.
|
InputTableConfig |
InputTableConfig.setRanges(List<Range> ranges)
Sets the input ranges to scan for all tables associated with this job.
|
InputTableConfig |
InputTableConfig.setUseIsolatedScanners(boolean useIsolatedScanners)
Controls the use of the
IsolatedScanner in this job. |
InputTableConfig |
InputTableConfig.setUseLocalIterators(boolean useLocalIterators)
Controls the use of the
ClientSideIteratorScanner in this job. |
Modifier and Type | Method and Description |
---|---|
protected static Map<String,InputTableConfig> |
AbstractInputFormat.getInputTableConfigs(org.apache.hadoop.mapreduce.JobContext context)
Fetches all
InputTableConfig s that have been set on the given job. |
Modifier and Type | Method and Description |
---|---|
static void |
AccumuloMultiTableInputFormat.setInputTableConfigs(org.apache.hadoop.mapreduce.Job job,
Map<String,InputTableConfig> configs)
Sets the
InputTableConfig objects on the given Hadoop configuration |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.