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
-
Method Summary
Modifier and TypeMethodDescriptionprotected 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
(List<IteratorSetting> iterators, Scanner scanner) Deprecated.protected void
setupIterators
(org.apache.hadoop.mapred.JobConf job, Scanner scanner) Deprecated.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 Details
-
RecordReaderBase
protected RecordReaderBase()
-
-
Method Details
-
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 classAbstractInputFormat.AbstractRecordReader<K,
V> - Parameters:
job
- the Hadoop job configurationtableName
- the table name for which the scanner is configured- Returns:
- List of iterator settings for given table
-
setupIterators
Deprecated.since 1.7.0; UsejobIterators(org.apache.hadoop.mapred.JobConf, java.lang.String)
instead.Apply the configured iterators to the scanner.- Parameters:
iterators
- the iterators to setscanner
- the scanner to configure
-
setupIterators
Deprecated.Apply the configured iterators from the configuration to the scanner.- Parameters:
job
- the job configurationscanner
- the scanner to configure
-
jobIterators(org.apache.hadoop.mapred.JobConf, java.lang.String)
instead.