org.apache.accumulo.core.client.mapreduce

Class InputFormatBase.RecordReaderBase<K,V>

java.lang.Object

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

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

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

All Implemented Interfaces:

Closeable, AutoCloseable

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.mapreduce.AbstractInputFormat.AbstractRecordReader

currentK, currentKey, currentV, 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.mapreduce.TaskAttemptContext context, Scanner scanner) Deprecated.
protected void	setupIterators(org.apache.hadoop.mapreduce.TaskAttemptContext context, Scanner scanner, RangeInputSplit split) Initialize a scanner over the given input split using this task attempt configuration.
protected void	setupIterators(org.apache.hadoop.mapreduce.TaskAttemptContext context, Scanner scanner, String tableName, RangeInputSplit split) Apply the configured iterators from the configuration to the scanner for the specified table name

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

close, getCurrentKey, getCurrentValue, getProgress, initialize

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

nextKeyValue

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordReaderBase

protected RecordReaderBase()

Method Detail

setupIterators

protected void setupIterators(org.apache.hadoop.mapreduce.TaskAttemptContext context,
                              Scanner scanner,
                              String tableName,
                              RangeInputSplit split)

Apply the configured iterators from the configuration to the scanner for the specified table name

Specified by:

setupIterators in class AbstractInputFormat.AbstractRecordReader<K,V>

Parameters:

context - the Hadoop context for the configured job

scanner - the scanner to configure

tableName - the table name for which the scanner is configured

Since:

1.6.0

setupIterators

@Deprecated
protected void setupIterators(org.apache.hadoop.mapreduce.TaskAttemptContext context,
                                          Scanner scanner)

Deprecated.

Apply the configured iterators from the configuration to the scanner.

Parameters:

context - the Hadoop context for the configured job

scanner - the scanner to configure

setupIterators

protected void setupIterators(org.apache.hadoop.mapreduce.TaskAttemptContext context,
                              Scanner scanner,
                              RangeInputSplit split)

Initialize a scanner over the given input split using this task attempt configuration.