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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RecordReaderBase()

Method Summary

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

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

close, getCurrentKey, getCurrentValue, getProgress, initialize, setupIterators

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 Details

RecordReaderBase

protected RecordReaderBase()

Method Details

contextIterators

protected List<IteratorSetting> contextIterators(org.apache.hadoop.mapreduce.TaskAttemptContext context,
 String tableName)

Description copied from class: AbstractInputFormat.AbstractRecordReader

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

Specified by:

contextIterators in class AbstractInputFormat.AbstractRecordReader<K,V>

Parameters:

context - the Hadoop context for the configured job

tableName - the table name for which the scanner is configured

Returns:

List of iterator settings for given table

setupIterators

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

Deprecated.

since 1.7.0; Use contextIterators(org.apache.hadoop.mapreduce.TaskAttemptContext, java.lang.String) instead.

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

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

Deprecated.

since 1.7.0; Use contextIterators(org.apache.hadoop.mapreduce.TaskAttemptContext, java.lang.String) instead.

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