org.apache.accumulo.core.client.mapreduce

Class InputFormatBase<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<K,V>

org.apache.accumulo.core.client.mapreduce.InputFormatBase<K,V>

Direct Known Subclasses:

AccumuloInputFormat, AccumuloRowInputFormat

public abstract class InputFormatBase<K,V>
extends org.apache.hadoop.mapreduce.InputFormat<K,V>

This abstract InputFormat class allows MapReduce jobs to use Accumulo as the source of K,V pairs.

Subclasses must implement a InputFormat.createRecordReader(InputSplit, TaskAttemptContext) to provide a RecordReader for K,V.

A static base class, RecordReaderBase, is provided to retrieve Accumulo Key/Value pairs, but one must implement its RecordReader.nextKeyValue() to transform them to the desired generic types K,V.

See AccumuloInputFormat for an example implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InputFormatBase.RangeInputSplit Deprecated. since 1.5.2; Use RangeInputSplit instead.
protected static class	InputFormatBase.RecordReaderBase<K,V> An abstract base class to be used to create RecordReader instances that convert from Accumulo Key/Value pairs to the user's K/V types.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
InputFormatBase()

Method Summary

Methods

Modifier and Type	Method and Description
static void	addIterator(org.apache.hadoop.conf.Configuration conf, IteratorSetting cfg) Deprecated. since 1.5.0; Use addIterator(Job, IteratorSetting) instead.
static void	addIterator(org.apache.hadoop.mapreduce.Job job, IteratorSetting cfg) Encode an iterator on the input for this job.
static void	disableAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use setAutoAdjustRanges(Job, boolean) 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) Deprecated. since 1.5.0; Use fetchColumns(Job, Collection) instead.
static void	fetchColumns(org.apache.hadoop.mapreduce.Job job, 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 job.
protected static Authorizations	getAuthorizations(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getScanAuthorizations(JobContext) instead.
protected static boolean	getAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getAutoAdjustRanges(JobContext) instead.
protected static boolean	getAutoAdjustRanges(org.apache.hadoop.mapreduce.JobContext context) Determines whether a configuration has auto-adjust ranges enabled.
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) Deprecated. since 1.5.0; Use getFetchedColumns(JobContext) instead.
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 context) Gets the columns to be mapped over from this job.
protected static String	getInputTableName(org.apache.hadoop.mapreduce.JobContext context) Gets the table name from the configuration.
protected static Instance	getInstance(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getInstance(JobContext) instead.
protected static Instance	getInstance(org.apache.hadoop.mapreduce.JobContext context) Initializes an Accumulo Instance based on the configuration.
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption>	getIteratorOptions(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getIterators(JobContext) instead.
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator>	getIterators(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getIterators(JobContext) instead.
protected static List<IteratorSetting>	getIterators(org.apache.hadoop.mapreduce.JobContext context) Gets a list of the iterator settings (for iterators to apply to a scanner) from this configuration.
protected static org.apache.log4j.Level	getLogLevel(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getLogLevel(JobContext) instead.
protected static org.apache.log4j.Level	getLogLevel(org.apache.hadoop.mapreduce.JobContext context) Gets the log level from this configuration.
protected static int	getMaxVersions(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use addIterator(Job, IteratorSetting) to add the VersioningIterator instead.
protected static String	getPrincipal(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getPrincipal(JobContext) instead.
protected static String	getPrincipal(org.apache.hadoop.mapreduce.JobContext context) Gets the user name from the configuration.
protected static List<Range>	getRanges(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getRanges(JobContext) instead.
protected static List<Range>	getRanges(org.apache.hadoop.mapreduce.JobContext context) Gets the ranges to scan over from a job.
protected static Authorizations	getScanAuthorizations(org.apache.hadoop.mapreduce.JobContext context) Gets the authorizations to set for the scans from the configuration.
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context) Read the metadata table to get tablets and match up ranges to them.
protected static String	getTablename(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getInputTableName(JobContext) instead.
protected static org.apache.accumulo.core.client.impl.TabletLocator	getTabletLocator(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getTabletLocator(JobContext) instead.
protected static org.apache.accumulo.core.client.impl.TabletLocator	getTabletLocator(org.apache.hadoop.mapreduce.JobContext context) Initializes an Accumulo TabletLocator based on the configuration.
protected static byte[]	getToken(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use getToken(JobContext) instead.
protected static byte[]	getToken(org.apache.hadoop.mapreduce.JobContext context) Gets the password from the configuration.
protected static String	getTokenClass(org.apache.hadoop.mapreduce.JobContext context) Gets the serialized token class from the configuration.
protected static Boolean	isConnectorInfoSet(org.apache.hadoop.mapreduce.JobContext context) Determines if the connector has been configured.
protected static boolean	isIsolated(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use isIsolated(JobContext) instead.
protected static boolean	isIsolated(org.apache.hadoop.mapreduce.JobContext context) Determines whether a configuration has isolation enabled.
protected static boolean	isOfflineScan(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use isOfflineScan(JobContext) instead.
protected static boolean	isOfflineScan(org.apache.hadoop.mapreduce.JobContext context) Determines whether a configuration has the offline table scan feature enabled.
static void	setAutoAdjustRanges(org.apache.hadoop.mapreduce.Job job, boolean enableFeature) Controls the automatic adjustment of ranges for this job.
static void	setConnectorInfo(org.apache.hadoop.mapreduce.Job job, String principal, AuthenticationToken token) Sets the connector information needed to communicate with Accumulo in this job.
static void	setInputInfo(org.apache.hadoop.conf.Configuration conf, String user, byte[] passwd, String table, Authorizations auths) Deprecated. since 1.5.0; Use setConnectorInfo(Job, String, AuthenticationToken), setInputTableName(Job, String), and setScanAuthorizations(Job, Authorizations) instead.
static void	setInputTableName(org.apache.hadoop.mapreduce.Job job, String tableName) Sets the name of the input table, over which this job will scan.
static void	setIsolated(org.apache.hadoop.conf.Configuration conf, boolean enable) Deprecated. since 1.5.0; Use setScanIsolation(Job, boolean) instead.
static void	setLocalIterators(org.apache.hadoop.conf.Configuration conf, boolean enable) Deprecated. since 1.5.0; Use setLocalIterators(Job, boolean) instead.
static void	setLocalIterators(org.apache.hadoop.mapreduce.Job job, boolean enableFeature) Controls the use of the ClientSideIteratorScanner in this job.
static void	setLogLevel(org.apache.hadoop.conf.Configuration conf, org.apache.log4j.Level level) Deprecated. since 1.5.0; Use setLogLevel(Job, Level) instead.
static void	setLogLevel(org.apache.hadoop.mapreduce.Job job, org.apache.log4j.Level level) Sets the log level for this job.
static void	setMaxVersions(org.apache.hadoop.conf.Configuration conf, int maxVersions) Deprecated. since 1.5.0; Use addIterator(Job, IteratorSetting) to add the VersioningIterator instead.
static void	setMockInstance(org.apache.hadoop.conf.Configuration conf, String instanceName) Deprecated. since 1.5.0; Use setMockInstance(Job, String) instead.
static void	setMockInstance(org.apache.hadoop.mapreduce.Job job, String instanceName) Configures a MockInstance for this job.
static void	setOfflineTableScan(org.apache.hadoop.mapreduce.Job job, boolean enableFeature) Enable reading offline tables.
static void	setRanges(org.apache.hadoop.conf.Configuration conf, Collection<Range> ranges) Deprecated. since 1.5.0; Use setRanges(Job, Collection) instead.
static void	setRanges(org.apache.hadoop.mapreduce.Job job, Collection<Range> ranges) Sets the input ranges to scan for this job.
static void	setScanAuthorizations(org.apache.hadoop.mapreduce.Job job, Authorizations auths) Sets the Authorizations used to scan.
static void	setScanIsolation(org.apache.hadoop.mapreduce.Job job, boolean enableFeature) Controls the use of the IsolatedScanner in this job.
static void	setScanOffline(org.apache.hadoop.conf.Configuration conf, boolean scanOff) Deprecated. since 1.5.0; Use setOfflineTableScan(Job, boolean) instead.
static void	setZooKeeperInstance(org.apache.hadoop.conf.Configuration conf, String instanceName, String zooKeepers) Deprecated. since 1.5.0; Use setZooKeeperInstance(Job, String, String) instead.
static void	setZooKeeperInstance(org.apache.hadoop.mapreduce.Job job, String instanceName, String zooKeepers) Configures a ZooKeeperInstance for this job.
protected static boolean	usesLocalIterators(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use usesLocalIterators(JobContext) instead.
protected static boolean	usesLocalIterators(org.apache.hadoop.mapreduce.JobContext context) Determines whether a configuration uses local iterators.
protected static void	validateOptions(org.apache.hadoop.conf.Configuration conf) Deprecated. since 1.5.0; Use validateOptions(JobContext) instead.
protected static void	validateOptions(org.apache.hadoop.mapreduce.JobContext context) Check whether a configuration is fully configured to be used with an Accumulo InputFormat.

Methods inherited from class org.apache.hadoop.mapreduce.InputFormat

createRecordReader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static final org.apache.log4j.Logger log

Constructor Detail

InputFormatBase

public InputFormatBase()

Method Detail

setConnectorInfo

public static void setConnectorInfo(org.apache.hadoop.mapreduce.Job job,
                    String principal,
                    AuthenticationToken token)
                             throws AccumuloSecurityException

Sets the connector information needed to communicate with Accumulo in this job.

WARNING: The serialized token is stored in the configuration and shared with all MapReduce tasks. It is BASE64 encoded to provide a charset safe conversion to a string, and is not intended to be secure.

Parameters:

job - the Hadoop job instance to be configured

principal - a valid Accumulo user name (user must have Table.CREATE permission)

token - the user's password

Throws:

AccumuloSecurityException

Since:

1.5.0

isConnectorInfoSet

protected static Boolean isConnectorInfoSet(org.apache.hadoop.mapreduce.JobContext context)

Determines if the connector has been configured.

Parameters:

context - the Hadoop context for the configured job

Returns:

true if the connector has been configured, false otherwise

Since:

1.5.0

See Also:

setConnectorInfo(Job, String, AuthenticationToken)

getPrincipal

protected static String getPrincipal(org.apache.hadoop.mapreduce.JobContext context)

Gets the user name from the configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

the user name

Since:

1.5.0

See Also:

setConnectorInfo(Job, String, AuthenticationToken)

getTokenClass

protected static String getTokenClass(org.apache.hadoop.mapreduce.JobContext context)

Gets the serialized token class from the configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

the user name

Since:

1.5.0

See Also:

setConnectorInfo(Job, String, AuthenticationToken)

getToken

protected static byte[] getToken(org.apache.hadoop.mapreduce.JobContext context)

Gets the password from the configuration. WARNING: The password is stored in the Configuration and shared with all MapReduce tasks; It is BASE64 encoded to provide a charset safe conversion to a string, and is not intended to be secure.

Parameters:

context - the Hadoop context for the configured job

Returns:

the decoded user password

Since:

1.5.0

See Also:

setConnectorInfo(Job, String, AuthenticationToken)

setZooKeeperInstance

public static void setZooKeeperInstance(org.apache.hadoop.mapreduce.Job job,
                        String instanceName,
                        String zooKeepers)

Configures a ZooKeeperInstance for this job.

Parameters:

job - the Hadoop job instance to be configured

instanceName - the Accumulo instance name

zooKeepers - a comma-separated list of zookeeper servers

Since:

1.5.0

setMockInstance

public static void setMockInstance(org.apache.hadoop.mapreduce.Job job,
                   String instanceName)

Configures a MockInstance for this job.

Parameters:

job - the Hadoop job instance to be configured

instanceName - the Accumulo instance name

Since:

1.5.0

getInstance

protected static Instance getInstance(org.apache.hadoop.mapreduce.JobContext context)

Initializes an Accumulo Instance based on the configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

an Accumulo instance

Since:

1.5.0

See Also:

setZooKeeperInstance(Job, String, String), setMockInstance(Job, String)

setLogLevel

public static void setLogLevel(org.apache.hadoop.mapreduce.Job job,
               org.apache.log4j.Level level)

Sets the log level for this job.

Parameters:

job - the Hadoop job instance to be configured

level - the logging level

Since:

1.5.0

getLogLevel

protected static org.apache.log4j.Level getLogLevel(org.apache.hadoop.mapreduce.JobContext context)

Gets the log level from this configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

the log level

Since:

1.5.0

See Also:

setLogLevel(Job, Level)

setInputTableName

public static void setInputTableName(org.apache.hadoop.mapreduce.Job job,
                     String tableName)

Sets the name of the input table, over which this job will scan.

Parameters:

job - the Hadoop job instance to be configured

tableName - the table to use when the tablename is null in the write call

Since:

1.5.0

getInputTableName

protected static String getInputTableName(org.apache.hadoop.mapreduce.JobContext context)

Gets the table name from the configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

the table name

Since:

1.5.0

See Also:

setInputTableName(Job, String)

setScanAuthorizations

public static void setScanAuthorizations(org.apache.hadoop.mapreduce.Job job,
                         Authorizations auths)

Sets the Authorizations used to scan. Must be a subset of the user's authorization. Defaults to the empty set.

Parameters:

job - the Hadoop job instance to be configured

auths - the user's authorizations

Since:

1.5.0

getScanAuthorizations

protected static Authorizations getScanAuthorizations(org.apache.hadoop.mapreduce.JobContext context)

Gets the authorizations to set for the scans from the configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

the Accumulo scan authorizations

Since:

1.5.0

See Also:

setScanAuthorizations(Job, Authorizations)

setRanges

public static void setRanges(org.apache.hadoop.mapreduce.Job job,
             Collection<Range> ranges)

Sets the input ranges to scan for this job. If not set, the entire table will be scanned.

Parameters:

job - the Hadoop job instance to be configured

ranges - the ranges that will be mapped over

Since:

1.5.0

getRanges

protected static List<Range> getRanges(org.apache.hadoop.mapreduce.JobContext context)
                                throws IOException

Gets the ranges to scan over from a job.

Parameters:

context - the Hadoop context for the configured job

Returns:

the ranges

Throws:

IOException - if the ranges have been encoded improperly

Since:

1.5.0

See Also:

setRanges(Job, Collection)

fetchColumns

public static void fetchColumns(org.apache.hadoop.mapreduce.Job job,
                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 job.

Parameters:

job - the Hadoop job instance to be configured

columnFamilyColumnQualifierPairs - 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.

Since:

1.5.0

getFetchedColumns

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 context)

Gets the columns to be mapped over from this job.

Parameters:

context - the Hadoop context for the configured job

Returns:

a set of columns

Since:

1.5.0

See Also:

fetchColumns(Job, Collection)

addIterator

public static void addIterator(org.apache.hadoop.mapreduce.Job job,
               IteratorSetting cfg)

Encode an iterator on the input for this job.

Parameters:

job - the Hadoop job instance to be configured

cfg - the configuration of the iterator

Since:

1.5.0

getIterators

protected static List<IteratorSetting> getIterators(org.apache.hadoop.mapreduce.JobContext context)

Gets a list of the iterator settings (for iterators to apply to a scanner) from this configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

a list of iterators

Since:

1.5.0

See Also:

addIterator(Job, IteratorSetting)

setAutoAdjustRanges

public static void setAutoAdjustRanges(org.apache.hadoop.mapreduce.Job job,
                       boolean enableFeature)

Controls the automatic adjustment of ranges for this job. This feature merges overlapping ranges, then splits them to align with tablet boundaries. Disabling this feature will cause exactly one Map task to be created for each specified range. The default setting is enabled. *

By default, this feature is enabled.

Parameters:

job - the Hadoop job instance to be configured

enableFeature - the feature is enabled if true, disabled otherwise

Since:

1.5.0

See Also:

setRanges(Job, Collection)

getAutoAdjustRanges

protected static boolean getAutoAdjustRanges(org.apache.hadoop.mapreduce.JobContext context)

Determines whether a configuration has auto-adjust ranges enabled.

Parameters:

context - the Hadoop context for the configured job

Returns:

false if the feature is disabled, true otherwise

Since:

1.5.0

See Also:

setAutoAdjustRanges(Job, boolean)

setScanIsolation

public static void setScanIsolation(org.apache.hadoop.mapreduce.Job job,
                    boolean enableFeature)

Controls the use of the IsolatedScanner in this job.

By default, this feature is disabled.

Parameters:

job - the Hadoop job instance to be configured

enableFeature - the feature is enabled if true, disabled otherwise

Since:

1.5.0

isIsolated

protected static boolean isIsolated(org.apache.hadoop.mapreduce.JobContext context)

Determines whether a configuration has isolation enabled.

Parameters:

context - the Hadoop context for the configured job

Returns:

true if the feature is enabled, false otherwise

Since:

1.5.0

See Also:

setScanIsolation(Job, boolean)

setLocalIterators

public static void setLocalIterators(org.apache.hadoop.mapreduce.Job job,
                     boolean enableFeature)

Controls the use of the ClientSideIteratorScanner in this job. Enabling this feature will cause the iterator stack to be constructed within the Map task, rather than within the Accumulo TServer. To use this feature, all classes needed for those iterators must be available on the classpath for the task.

By default, this feature is disabled.

Parameters:

job - the Hadoop job instance to be configured

enableFeature - the feature is enabled if true, disabled otherwise

Since:

1.5.0

usesLocalIterators

protected static boolean usesLocalIterators(org.apache.hadoop.mapreduce.JobContext context)

Determines whether a configuration uses local iterators.

Parameters:

context - the Hadoop context for the configured job

Returns:

true if the feature is enabled, false otherwise

Since:

1.5.0

See Also:

setLocalIterators(Job, boolean)

setOfflineTableScan

public static void setOfflineTableScan(org.apache.hadoop.mapreduce.Job job,
                       boolean enableFeature)

Enable reading offline tables. By default, this feature is disabled and only online tables are scanned. This will make the map reduce job directly read the table's files. If the table is not offline, then the job will fail. If the table comes online during the map reduce job, it is 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 mapper's 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 it is 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.

By default, this feature is disabled.

Parameters:

job - the Hadoop job instance to be configured

enableFeature - the feature is enabled if true, disabled otherwise

Since:

1.5.0

isOfflineScan

protected static boolean isOfflineScan(org.apache.hadoop.mapreduce.JobContext context)

Determines whether a configuration has the offline table scan feature enabled.

Parameters:

context - the Hadoop context for the configured job

Returns:

true if the feature is enabled, false otherwise

Since:

1.5.0

See Also:

setOfflineTableScan(Job, boolean)

getTabletLocator

protected static org.apache.accumulo.core.client.impl.TabletLocator getTabletLocator(org.apache.hadoop.mapreduce.JobContext context)
                                                                              throws TableNotFoundException

Initializes an Accumulo TabletLocator based on the configuration.

Parameters:

context - the Hadoop context for the configured job

Returns:

an Accumulo tablet locator

Throws:

TableNotFoundException - if the table name set on the configuration doesn't exist

Since:

1.5.0

validateOptions

protected static void validateOptions(org.apache.hadoop.mapreduce.JobContext context)
                               throws IOException

Check whether a configuration is fully configured to be used with an Accumulo InputFormat.

Parameters:

context - the Hadoop context for the configured job

Throws:

IOException - if the context is improperly configured

Since:

1.5.0

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                       throws IOException

Read the metadata table to get tablets and match up ranges to them.

Specified by:

getSplits in class org.apache.hadoop.mapreduce.InputFormat<K,V>

Throws:

IOException

setIsolated

@Deprecated
public static void setIsolated(org.apache.hadoop.conf.Configuration conf,
                          boolean enable)

Deprecated. since 1.5.0; Use setScanIsolation(Job, boolean) instead.

setLocalIterators

@Deprecated
public static void setLocalIterators(org.apache.hadoop.conf.Configuration conf,
                                boolean enable)

Deprecated. since 1.5.0; Use setLocalIterators(Job, boolean) instead.

setInputInfo

@Deprecated
public static void setInputInfo(org.apache.hadoop.conf.Configuration conf,
                           String user,
                           byte[] passwd,
                           String table,
                           Authorizations auths)

Deprecated. since 1.5.0; Use setConnectorInfo(Job, String, AuthenticationToken), setInputTableName(Job, String), and setScanAuthorizations(Job, Authorizations) instead.

setZooKeeperInstance

@Deprecated
public static void setZooKeeperInstance(org.apache.hadoop.conf.Configuration conf,
                                   String instanceName,
                                   String zooKeepers)

Deprecated. since 1.5.0; Use setZooKeeperInstance(Job, String, String) instead.

setMockInstance

@Deprecated
public static void setMockInstance(org.apache.hadoop.conf.Configuration conf,
                              String instanceName)

Deprecated. since 1.5.0; Use setMockInstance(Job, String) instead.

setRanges

@Deprecated
public static void setRanges(org.apache.hadoop.conf.Configuration conf,
                        Collection<Range> ranges)

Deprecated. since 1.5.0; Use setRanges(Job, Collection) instead.

disableAutoAdjustRanges

@Deprecated
public static void disableAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use setAutoAdjustRanges(Job, boolean) instead.

setMaxVersions

@Deprecated
public static void setMaxVersions(org.apache.hadoop.conf.Configuration conf,
                             int maxVersions)
                           throws IOException

Deprecated. since 1.5.0; Use addIterator(Job, IteratorSetting) to add the VersioningIterator instead.

Throws:

IOException

setScanOffline

@Deprecated
public static void setScanOffline(org.apache.hadoop.conf.Configuration conf,
                             boolean scanOff)

Deprecated. since 1.5.0; Use setOfflineTableScan(Job, boolean) instead.

fetchColumns

@Deprecated
public 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)

Deprecated. since 1.5.0; Use fetchColumns(Job, Collection) instead.

setLogLevel

@Deprecated
public static void setLogLevel(org.apache.hadoop.conf.Configuration conf,
                          org.apache.log4j.Level level)

Deprecated. since 1.5.0; Use setLogLevel(Job, Level) instead.

addIterator

@Deprecated
public static void addIterator(org.apache.hadoop.conf.Configuration conf,
                          IteratorSetting cfg)

Deprecated. since 1.5.0; Use addIterator(Job, IteratorSetting) instead.

isIsolated

@Deprecated
protected static boolean isIsolated(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use isIsolated(JobContext) instead.

usesLocalIterators

@Deprecated
protected static boolean usesLocalIterators(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use usesLocalIterators(JobContext) instead.

getPrincipal

@Deprecated
protected static String getPrincipal(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getPrincipal(JobContext) instead.

getToken

@Deprecated
protected static byte[] getToken(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getToken(JobContext) instead.

getTablename

@Deprecated
protected static String getTablename(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getInputTableName(JobContext) instead.

getAuthorizations

@Deprecated
protected static Authorizations getAuthorizations(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getScanAuthorizations(JobContext) instead.

getInstance

@Deprecated
protected static Instance getInstance(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getInstance(JobContext) instead.

getTabletLocator

@Deprecated
protected static org.apache.accumulo.core.client.impl.TabletLocator getTabletLocator(org.apache.hadoop.conf.Configuration conf)
                                                                              throws TableNotFoundException

Deprecated. since 1.5.0; Use getTabletLocator(JobContext) instead.

Throws:

TableNotFoundException

getRanges

@Deprecated
protected static List<Range> getRanges(org.apache.hadoop.conf.Configuration conf)
                                throws IOException

Deprecated. since 1.5.0; Use getRanges(JobContext) instead.

Throws:

IOException

getFetchedColumns

@Deprecated
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)

Deprecated. since 1.5.0; Use getFetchedColumns(JobContext) instead.

getAutoAdjustRanges

@Deprecated
protected static boolean getAutoAdjustRanges(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getAutoAdjustRanges(JobContext) instead.

getLogLevel

@Deprecated
protected static org.apache.log4j.Level getLogLevel(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getLogLevel(JobContext) instead.

validateOptions

@Deprecated
protected static void validateOptions(org.apache.hadoop.conf.Configuration conf)
                               throws IOException

Deprecated. since 1.5.0; Use validateOptions(JobContext) instead.

Throws:

IOException

getMaxVersions

@Deprecated
protected static int getMaxVersions(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use addIterator(Job, IteratorSetting) to add the VersioningIterator instead.

isOfflineScan

@Deprecated
protected static boolean isOfflineScan(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use isOfflineScan(JobContext) instead.

getIterators

@Deprecated
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> getIterators(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getIterators(JobContext) instead.

getIteratorOptions

@Deprecated
protected static List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> getIteratorOptions(org.apache.hadoop.conf.Configuration conf)

Deprecated. since 1.5.0; Use getIterators(JobContext) instead.