public abstract class InputFormatBase<K,V>
extends org.apache.hadoop.mapreduce.InputFormat<K,V>
Modifier and Type | Class and Description |
---|---|
protected static class |
InputFormatBase.RecordReaderBase<K,V> |
static class |
InputFormatBase.RegexType
Deprecated.
since 1.4 use
RegExFilter and addIterator(Configuration, IteratorSetting) |
Modifier and Type | Field and Description |
---|---|
protected static org.apache.log4j.Logger |
log |
Constructor and Description |
---|
InputFormatBase() |
Modifier and Type | Method and Description |
---|---|
static void |
addIterator(org.apache.hadoop.conf.Configuration conf,
IteratorSetting cfg)
Encode an iterator on the input for this configuration object.
|
static void |
addIterator(org.apache.hadoop.mapreduce.JobContext job,
IteratorSetting cfg)
Deprecated.
Use
addIterator(Configuration,IteratorSetting) instead |
static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> |
deserializeFetchedColumns(String[] serialized) |
static void |
disableAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf)
Disables the adjustment of ranges for this configuration object.
|
static void |
disableAutoAdjustRanges(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
disableAutoAdjustRanges(Configuration) instead |
static void |
fetchColumns(org.apache.hadoop.conf.Configuration conf,
Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)
Restricts the columns that will be mapped over for this configuration object.
|
static void |
fetchColumns(org.apache.hadoop.mapreduce.JobContext job,
Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)
Deprecated.
Use
fetchColumns(Configuration,Collection) instead |
protected static Authorizations |
getAuthorizations(org.apache.hadoop.conf.Configuration conf)
Gets the authorizations to set for the scans from the configuration.
|
protected static Authorizations |
getAuthorizations(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getAuthorizations(Configuration) instead |
protected static boolean |
getAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf)
Determines whether a configuration has auto-adjust ranges enabled.
|
protected static boolean |
getAutoAdjustRanges(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getAutoAdjustRanges(Configuration) instead |
static org.apache.hadoop.conf.Configuration |
getConfiguration(org.apache.hadoop.mapreduce.JobContext context) |
protected static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> |
getFetchedColumns(org.apache.hadoop.conf.Configuration conf)
Gets the columns to be mapped over from this configuration object.
|
protected static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> |
getFetchedColumns(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getFetchedColumns(Configuration) instead |
protected static Instance |
getInstance(org.apache.hadoop.conf.Configuration conf)
Initializes an Accumulo
Instance based on the configuration. |
protected static Instance |
getInstance(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getInstance(Configuration) instead |
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> |
getIteratorOptions(org.apache.hadoop.conf.Configuration conf)
Gets a list of the iterator options specified on this configuration.
|
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> |
getIteratorOptions(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getIteratorOptions(Configuration) instead |
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> |
getIterators(org.apache.hadoop.conf.Configuration conf)
Gets a list of the iterator settings (for iterators to apply to a scanner) from this configuration.
|
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> |
getIterators(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getIterators(Configuration) instead |
protected static org.apache.log4j.Level |
getLogLevel(org.apache.hadoop.conf.Configuration conf)
Gets the log level from this configuration.
|
protected static org.apache.log4j.Level |
getLogLevel(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getLogLevel(Configuration) instead |
protected static int |
getMaxVersions(org.apache.hadoop.conf.Configuration conf)
Gets the maxVersions to use for the
VersioningIterator from this configuration. |
protected static int |
getMaxVersions(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getMaxVersions(Configuration) instead |
protected static byte[] |
getPassword(org.apache.hadoop.conf.Configuration conf)
Gets the password from the configuration.
|
protected static byte[] |
getPassword(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getPassword(Configuration) instead |
protected static List<Range> |
getRanges(org.apache.hadoop.conf.Configuration conf)
Gets the ranges to scan over from a configuration object.
|
protected static List<Range> |
getRanges(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getRanges(Configuration) instead |
protected static String |
getRegex(org.apache.hadoop.mapreduce.JobContext job,
InputFormatBase.RegexType type)
Deprecated.
since 1.4 use
RegExFilter and addIterator(Configuration, IteratorSetting) |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext job)
Read the metadata table to get tablets and match up ranges to them.
|
protected static String |
getTablename(org.apache.hadoop.conf.Configuration conf)
Gets the table name from the configuration.
|
protected static String |
getTablename(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getTablename(Configuration) instead |
protected static org.apache.accumulo.core.client.impl.TabletLocator |
getTabletLocator(org.apache.hadoop.conf.Configuration conf)
Initializes an Accumulo
TabletLocator based on the configuration. |
protected static org.apache.accumulo.core.client.impl.TabletLocator |
getTabletLocator(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getTabletLocator(Configuration) instead |
protected static String |
getUsername(org.apache.hadoop.conf.Configuration conf)
Gets the user name from the configuration.
|
protected static String |
getUsername(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getUsername(Configuration) instead |
protected static boolean |
isIsolated(org.apache.hadoop.conf.Configuration conf)
Determines whether a configuration has isolation enabled.
|
protected static boolean |
isIsolated(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
isIsolated(Configuration) instead |
protected static boolean |
isOfflineScan(org.apache.hadoop.conf.Configuration conf) |
static String[] |
serializeColumns(Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs) |
static void |
setInputInfo(org.apache.hadoop.conf.Configuration conf,
String user,
byte[] passwd,
String table,
Authorizations auths)
Initialize the user, table, and authorization information for the configuration object that will be used with an Accumulo InputFormat.
|
static void |
setInputInfo(org.apache.hadoop.mapreduce.JobContext job,
String user,
byte[] passwd,
String table,
Authorizations auths)
Deprecated.
|
static void |
setIsolated(org.apache.hadoop.conf.Configuration conf,
boolean enable)
Enable or disable use of the
IsolatedScanner in this configuration object. |
static void |
setIsolated(org.apache.hadoop.mapreduce.JobContext job,
boolean enable)
Deprecated.
Use
setIsolated(Configuration,boolean) instead |
static void |
setIterator(org.apache.hadoop.mapreduce.JobContext job,
int priority,
String iteratorClass,
String iteratorName)
Deprecated.
since 1.4, see
addIterator(Configuration, IteratorSetting) |
static void |
setIteratorOption(org.apache.hadoop.mapreduce.JobContext job,
String iteratorName,
String key,
String value)
Deprecated.
since 1.4, see
addIterator(Configuration, IteratorSetting) |
static void |
setLocalIterators(org.apache.hadoop.conf.Configuration conf,
boolean enable)
Enable or disable use of the
ClientSideIteratorScanner in this Configuration object. |
static void |
setLocalIterators(org.apache.hadoop.mapreduce.JobContext job,
boolean enable)
Deprecated.
Use
setLocalIterators(Configuration,boolean) instead |
static void |
setLogLevel(org.apache.hadoop.conf.Configuration conf,
org.apache.log4j.Level level)
Sets the log level for this configuration object.
|
static void |
setLogLevel(org.apache.hadoop.mapreduce.JobContext job,
org.apache.log4j.Level level)
Deprecated.
Use
setLogLevel(Configuration,Level) instead |
static void |
setMaxVersions(org.apache.hadoop.conf.Configuration conf,
int maxVersions)
Sets the max # of values that may be returned for an individual Accumulo cell.
|
static void |
setMaxVersions(org.apache.hadoop.mapreduce.JobContext job,
int maxVersions)
Deprecated.
Use
setMaxVersions(Configuration,int) instead |
static void |
setMockInstance(org.apache.hadoop.conf.Configuration conf,
String instanceName)
Configure a
MockInstance for this configuration object. |
static void |
setMockInstance(org.apache.hadoop.mapreduce.JobContext job,
String instanceName)
Deprecated.
Use
setMockInstance(Configuration,String) instead |
static void |
setRanges(org.apache.hadoop.conf.Configuration conf,
Collection<Range> ranges)
Set the ranges to map over for this configuration object.
|
static void |
setRanges(org.apache.hadoop.mapreduce.JobContext job,
Collection<Range> ranges)
Deprecated.
Use
setRanges(Configuration,Collection) instead |
static void |
setRegex(org.apache.hadoop.mapreduce.JobContext job,
InputFormatBase.RegexType type,
String regex)
Deprecated.
since 1.4 use
addIterator(Configuration, IteratorSetting) |
static void |
setScanOffline(org.apache.hadoop.conf.Configuration conf,
boolean scanOff)
Enable reading offline tables.
|
static void |
setZooKeeperInstance(org.apache.hadoop.conf.Configuration conf,
String instanceName,
String zooKeepers)
Configure a
ZooKeeperInstance for this configuration object. |
static void |
setZooKeeperInstance(org.apache.hadoop.mapreduce.JobContext job,
String instanceName,
String zooKeepers)
Deprecated.
|
protected static boolean |
usesLocalIterators(org.apache.hadoop.conf.Configuration conf)
Determines whether a configuration uses local iterators.
|
protected static boolean |
usesLocalIterators(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
usesLocalIterators(Configuration) instead |
protected static void |
validateOptions(org.apache.hadoop.conf.Configuration conf)
Check whether a configuration is fully configured to be used with an Accumulo
InputFormat . |
protected static void |
validateOptions(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
validateOptions(Configuration) instead |
@Deprecated public static void setIsolated(org.apache.hadoop.mapreduce.JobContext job, boolean enable)
setIsolated(Configuration,boolean)
insteadpublic static void setIsolated(org.apache.hadoop.conf.Configuration conf, boolean enable)
IsolatedScanner
in this configuration object. By default it is not enabled.conf
- The Hadoop configuration objectenable
- if true, enable usage of the IsolatedScanner. Otherwise, disable.@Deprecated public static void setLocalIterators(org.apache.hadoop.mapreduce.JobContext job, boolean enable)
setLocalIterators(Configuration,boolean)
insteadpublic static void setLocalIterators(org.apache.hadoop.conf.Configuration conf, boolean enable)
ClientSideIteratorScanner
in this Configuration object. By default it is not enabled.conf
- The Hadoop configuration objectenable
- if true, enable usage of the ClientSideInteratorScanner. Otherwise, disable.@Deprecated public static void setInputInfo(org.apache.hadoop.mapreduce.JobContext job, String user, byte[] passwd, String table, Authorizations auths)
setInputInfo(Configuration,String,byte[],String,Authorizations)
insteadpublic static void setInputInfo(org.apache.hadoop.conf.Configuration conf, String user, byte[] passwd, String table, Authorizations auths)
conf
- the Hadoop configuration objectuser
- a valid accumulo userpasswd
- the user's passwordtable
- the table to readauths
- the authorizations used to restrict data read@Deprecated public static void setZooKeeperInstance(org.apache.hadoop.mapreduce.JobContext job, String instanceName, String zooKeepers)
setZooKeeperInstance(Configuration,String,String)
insteadpublic static void setZooKeeperInstance(org.apache.hadoop.conf.Configuration conf, String instanceName, String zooKeepers)
ZooKeeperInstance
for this configuration object.conf
- the Hadoop configuration objectinstanceName
- the accumulo instance namezooKeepers
- a comma-separated list of zookeeper servers@Deprecated public static void setMockInstance(org.apache.hadoop.mapreduce.JobContext job, String instanceName)
setMockInstance(Configuration,String)
insteadpublic static void setMockInstance(org.apache.hadoop.conf.Configuration conf, String instanceName)
MockInstance
for this configuration object.conf
- the Hadoop configuration objectinstanceName
- the accumulo instance name@Deprecated public static void setRanges(org.apache.hadoop.mapreduce.JobContext job, Collection<Range> ranges)
setRanges(Configuration,Collection)
insteadpublic static void setRanges(org.apache.hadoop.conf.Configuration conf, Collection<Range> ranges)
conf
- the Hadoop configuration objectranges
- the ranges that will be mapped over@Deprecated public static void disableAutoAdjustRanges(org.apache.hadoop.mapreduce.JobContext job)
disableAutoAdjustRanges(Configuration)
insteadpublic static void disableAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf)
setRanges(Configuration, Collection)
.conf
- the Hadoop configuration object@Deprecated public static void setRegex(org.apache.hadoop.mapreduce.JobContext job, InputFormatBase.RegexType type, String regex)
addIterator(Configuration, IteratorSetting)
job
- type
- regex
- RegExFilter.setRegexs(IteratorSetting, String, String, String, String, boolean)
@Deprecated public static void setMaxVersions(org.apache.hadoop.mapreduce.JobContext job, int maxVersions) throws IOException
setMaxVersions(Configuration,int)
insteadIOException
public static void setMaxVersions(org.apache.hadoop.conf.Configuration conf, int maxVersions) throws IOException
conf
- the Hadoop configuration objectmaxVersions
- the max number of versions per accumulo cellIOException
- if maxVersions is < 1public static void setScanOffline(org.apache.hadoop.conf.Configuration conf, boolean scanOff)
Enable reading offline tables. This will make the map reduce job directly read the tables files. If the table is not offline, then the job will fail. If the table comes online during the map reduce job, its likely that the job will fail.
To use this option, the map reduce user will need access to read the accumulo directory in HDFS.
Reading the offline table will create the scan time iterator stack in the map process. So any iterators that are configured for the table will need to be on the mappers classpath.
One way to use this feature is to clone a table, take the clone offline, and use the clone as the input table for a map reduce job. If you plan to map reduce over the data many times, it may be better to the compact the table, clone it, take it offline, and use the clone for all map reduce jobs. The reason to do this is that compaction will reduce each tablet in the table to one file, and its faster to read from one file.
There are two possible advantages to reading a tables file directly out of HDFS. First, you may see better read performance. Second, it will support speculative execution better. When reading an online table speculative execution can put more load on an already slow tablet server.
conf
- the jobscanOff
- pass true to read offline tables@Deprecated public static void fetchColumns(org.apache.hadoop.mapreduce.JobContext job, Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)
fetchColumns(Configuration,Collection)
insteadpublic static void fetchColumns(org.apache.hadoop.conf.Configuration conf, Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)
conf
- the Hadoop configuration objectcolumnFamilyColumnQualifierPairs
- A pair of Text
objects corresponding to column family and column qualifier. If the column qualifier is null, the entire column family is
selected. An empty set is the default and is equivalent to scanning the all columns.public static String[] serializeColumns(Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)
@Deprecated public static void setLogLevel(org.apache.hadoop.mapreduce.JobContext job, org.apache.log4j.Level level)
setLogLevel(Configuration,Level)
insteadpublic static void setLogLevel(org.apache.hadoop.conf.Configuration conf, org.apache.log4j.Level level)
conf
- the Hadoop configuration objectlevel
- the logging level@Deprecated public static void addIterator(org.apache.hadoop.mapreduce.JobContext job, IteratorSetting cfg)
addIterator(Configuration,IteratorSetting)
insteadpublic static void addIterator(org.apache.hadoop.conf.Configuration conf, IteratorSetting cfg)
conf
- The Hadoop configuration in which to save the iterator configurationcfg
- The configuration of the iterator@Deprecated public static void setIterator(org.apache.hadoop.mapreduce.JobContext job, int priority, String iteratorClass, String iteratorName)
addIterator(Configuration, IteratorSetting)
job
- the jobpriority
- the priorityiteratorClass
- the iterator classiteratorName
- the iterator name@Deprecated public static void setIteratorOption(org.apache.hadoop.mapreduce.JobContext job, String iteratorName, String key, String value)
addIterator(Configuration, IteratorSetting)
job
- the jobiteratorName
- the iterator name. Should correspond to an iterator set w/ a prior setIterator call.key
- the keyvalue
- the value@Deprecated protected static boolean isIsolated(org.apache.hadoop.mapreduce.JobContext job)
isIsolated(Configuration)
insteadprotected static boolean isIsolated(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetIsolated(Configuration, boolean)
@Deprecated protected static boolean usesLocalIterators(org.apache.hadoop.mapreduce.JobContext job)
usesLocalIterators(Configuration)
insteadprotected static boolean usesLocalIterators(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetLocalIterators(Configuration, boolean)
@Deprecated protected static String getUsername(org.apache.hadoop.mapreduce.JobContext job)
getUsername(Configuration)
insteadprotected static String getUsername(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetInputInfo(Configuration, String, byte[], String, Authorizations)
@Deprecated protected static byte[] getPassword(org.apache.hadoop.mapreduce.JobContext job)
getPassword(Configuration)
insteadprotected static byte[] getPassword(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetInputInfo(Configuration, String, byte[], String, Authorizations)
@Deprecated protected static String getTablename(org.apache.hadoop.mapreduce.JobContext job)
getTablename(Configuration)
insteadprotected static String getTablename(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetInputInfo(Configuration, String, byte[], String, Authorizations)
@Deprecated protected static Authorizations getAuthorizations(org.apache.hadoop.mapreduce.JobContext job)
getAuthorizations(Configuration)
insteadprotected static Authorizations getAuthorizations(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetInputInfo(Configuration, String, byte[], String, Authorizations)
@Deprecated protected static Instance getInstance(org.apache.hadoop.mapreduce.JobContext job)
getInstance(Configuration)
insteadprotected static Instance getInstance(org.apache.hadoop.conf.Configuration conf)
Instance
based on the configuration.conf
- the Hadoop configuration objectsetZooKeeperInstance(Configuration, String, String)
,
setMockInstance(Configuration, String)
@Deprecated protected static org.apache.accumulo.core.client.impl.TabletLocator getTabletLocator(org.apache.hadoop.mapreduce.JobContext job) throws TableNotFoundException
getTabletLocator(Configuration)
insteadTableNotFoundException
protected static org.apache.accumulo.core.client.impl.TabletLocator getTabletLocator(org.apache.hadoop.conf.Configuration conf) throws TableNotFoundException
TabletLocator
based on the configuration.conf
- the Hadoop configuration objectTableNotFoundException
- if the table name set on the configuration doesn't exist@Deprecated protected static List<Range> getRanges(org.apache.hadoop.mapreduce.JobContext job) throws IOException
getRanges(Configuration)
insteadIOException
protected static List<Range> getRanges(org.apache.hadoop.conf.Configuration conf) throws IOException
conf
- the Hadoop configuration objectIOException
- if the ranges have been encoded improperlysetRanges(Configuration, Collection)
@Deprecated protected static String getRegex(org.apache.hadoop.mapreduce.JobContext job, InputFormatBase.RegexType type)
@Deprecated protected static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> getFetchedColumns(org.apache.hadoop.mapreduce.JobContext job)
getFetchedColumns(Configuration)
insteadprotected static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> getFetchedColumns(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectfetchColumns(Configuration, Collection)
public static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> deserializeFetchedColumns(String[] serialized)
@Deprecated protected static boolean getAutoAdjustRanges(org.apache.hadoop.mapreduce.JobContext job)
getAutoAdjustRanges(Configuration)
insteadprotected static boolean getAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectdisableAutoAdjustRanges(Configuration)
@Deprecated protected static org.apache.log4j.Level getLogLevel(org.apache.hadoop.mapreduce.JobContext job)
getLogLevel(Configuration)
insteadprotected static org.apache.log4j.Level getLogLevel(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectsetLogLevel(Configuration, Level)
@Deprecated protected static void validateOptions(org.apache.hadoop.mapreduce.JobContext job) throws IOException
validateOptions(Configuration)
insteadIOException
protected static void validateOptions(org.apache.hadoop.conf.Configuration conf) throws IOException
InputFormat
.conf
- the Hadoop configuration objectIOException
- if the configuration is improperly configured@Deprecated protected static int getMaxVersions(org.apache.hadoop.mapreduce.JobContext job)
getMaxVersions(Configuration)
insteadprotected static int getMaxVersions(org.apache.hadoop.conf.Configuration conf)
VersioningIterator
from this configuration.conf
- the Hadoop configuration objectsetMaxVersions(Configuration, int)
protected static boolean isOfflineScan(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> getIterators(org.apache.hadoop.mapreduce.JobContext job)
getIterators(Configuration)
insteadprotected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> getIterators(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectaddIterator(Configuration, IteratorSetting)
@Deprecated protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> getIteratorOptions(org.apache.hadoop.mapreduce.JobContext job)
getIteratorOptions(Configuration)
insteadprotected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> getIteratorOptions(org.apache.hadoop.conf.Configuration conf)
conf
- the Hadoop configuration objectaddIterator(Configuration, IteratorSetting)
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext job) throws IOException
getSplits
in class org.apache.hadoop.mapreduce.InputFormat<K,V>
IOException
public static org.apache.hadoop.conf.Configuration getConfiguration(org.apache.hadoop.mapreduce.JobContext context)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.