org.apache.accumulo.core.client.mapred

Class InputFormatBase.RecordReaderBase<K,V>

java.lang.Object

org.apache.accumulo.core.client.mapred.AbstractInputFormat.AbstractRecordReader<K,V>

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

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<K,V>

Enclosing class:

InputFormatBase<K,V>

protected abstract static class InputFormatBase.RecordReaderBase<K,V>
extends AbstractInputFormat.AbstractRecordReader<K,V>

Field Summary

Fields inherited from class org.apache.accumulo.core.client.mapred.AbstractInputFormat.AbstractRecordReader

currentKey, numKeysRead, scannerBase, scannerIterator, split

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RecordReaderBase()

Method Summary

Modifier and Type	Method and Description
protected List<IteratorSetting>	jobIterators(org.apache.hadoop.mapred.JobConf job, String tableName) Extracts Iterators settings from the context to be used by RecordReader.
protected void	setupIterators(org.apache.hadoop.mapred.JobConf job, Scanner scanner) Deprecated.
protected void	setupIterators(List<IteratorSetting> iterators, Scanner scanner) Deprecated. since 1.7.0; Use jobIterators(org.apache.hadoop.mapred.JobConf, java.lang.String) instead.

Methods inherited from class org.apache.accumulo.core.client.mapred.AbstractInputFormat.AbstractRecordReader

close, getPos, getProgress, initialize, setupIterators

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.mapred.RecordReader

createKey, createValue, next

Constructor Detail

RecordReaderBase

protected RecordReaderBase()

Method Detail

jobIterators

protected List<IteratorSetting> jobIterators(org.apache.hadoop.mapred.JobConf job,
                                             String tableName)

Description copied from class: AbstractInputFormat.AbstractRecordReader

Extracts Iterators settings from the context to be used by RecordReader.

Specified by:

jobIterators in class AbstractInputFormat.AbstractRecordReader<K,V>

Parameters:

job - the Hadoop job configuration

tableName - the table name for which the scanner is configured

Returns:

List of iterator settings for given table

setupIterators

@Deprecated
protected void setupIterators(List<IteratorSetting> iterators,
                                          Scanner scanner)

Deprecated. since 1.7.0; Use jobIterators(org.apache.hadoop.mapred.JobConf, java.lang.String) instead.

Apply the configured iterators to the scanner.

Parameters:

iterators - the iterators to set

scanner - the scanner to configure

setupIterators

@Deprecated
protected void setupIterators(org.apache.hadoop.mapred.JobConf job,
                                          Scanner scanner)

Deprecated.

Apply the configured iterators from the configuration to the scanner.

Parameters:

job - the job configuration

scanner - the scanner to configure