protected abstract static class InputFormatBase.RecordReaderBase<K,V>
extends org.apache.hadoop.mapreduce.RecordReader<K,V>
Modifier and Type | Field and Description |
---|---|
protected K |
currentK |
protected Key |
currentKey |
protected V |
currentV |
protected Value |
currentValue |
protected long |
numKeysRead |
protected Iterator<Map.Entry<Key,Value>> |
scannerIterator |
protected RangeInputSplit |
split |
Modifier | Constructor and Description |
---|---|
protected |
InputFormatBase.RecordReaderBase() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
K |
getCurrentKey() |
V |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext attempt)
Initialize a scanner over the given input split using this task attempt configuration.
|
protected void |
setupIterators(Scanner scanner,
List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> iterators,
List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> options)
Apply the configured iterators from the configuration to the scanner.
|
protected void |
setupMaxVersions(Scanner scanner,
int maxVersions)
If maxVersions has been set, configure a
VersioningIterator at priority 0 for this scanner. |
protected boolean |
setupRegex(org.apache.hadoop.mapreduce.TaskAttemptContext attempt,
Scanner scanner)
Deprecated.
since 1.4, configure
RegExFilter instead. |
protected long numKeysRead
protected RangeInputSplit split
protected K currentK
protected V currentV
protected Key currentKey
protected Value currentValue
@Deprecated protected boolean setupRegex(org.apache.hadoop.mapreduce.TaskAttemptContext attempt, Scanner scanner) throws AccumuloException
RegExFilter
instead.AccumuloException
protected void setupIterators(Scanner scanner, List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> iterators, List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> options) throws AccumuloException
scanner
- the scanner to configureiterators
- the iterators to configure on the scanneroptions
- options for each configured iteratorAccumuloException
protected void setupMaxVersions(Scanner scanner, int maxVersions)
VersioningIterator
at priority 0 for this scanner.scanner
- the scanner to configuremaxVersions
- the number of versions to returnpublic void initialize(org.apache.hadoop.mapreduce.InputSplit inSplit, org.apache.hadoop.mapreduce.TaskAttemptContext attempt) throws IOException
initialize
in class org.apache.hadoop.mapreduce.RecordReader<K,V>
IOException
public void close()
public float getProgress() throws IOException
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<K,V>
IOException
public K getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<K,V>
IOException
InterruptedException
public V getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<K,V>
IOException
InterruptedException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.