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, scannerIterator, split

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RecordReaderBase()

Method Summary

Modifier and Type	Method and Description
protected void	setupIterators(org.apache.hadoop.mapred.JobConf job, Scanner scanner) Deprecated.
protected void	setupIterators(org.apache.hadoop.mapred.JobConf job, Scanner scanner, String tableName, RangeInputSplit split) Configures the iterators on a scanner for the given table name.
protected void	setupIterators(List<IteratorSetting> iterators, Scanner scanner) Apply the configured iterators to the scanner.

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

close, getPos, getProgress, initialize

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

setupIterators

protected void setupIterators(org.apache.hadoop.mapred.JobConf job,
                              Scanner scanner,
                              String tableName,
                              RangeInputSplit split)

Description copied from class: AbstractInputFormat.AbstractRecordReader

Configures the iterators on a scanner for the given table name.

Specified by:

setupIterators in class AbstractInputFormat.AbstractRecordReader<K,V>

Parameters:

job - the Hadoop job configuration

scanner - the scanner for which to configure the iterators

tableName - the table name for which the scanner is configured

setupIterators

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

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