org.apache.hadoop.hbase.mapreduce

Class NMapInputFormat.SingleRecordReader<K,V>

java.lang.Object

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

org.apache.hadoop.hbase.mapreduce.NMapInputFormat.SingleRecordReader<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

NMapInputFormat

private static class NMapInputFormat.SingleRecordReader<K,V>
extends org.apache.hadoop.mapreduce.RecordReader<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
private K	key
(package private) boolean	providedKey
private V	value

Constructor Summary

Constructors

Constructor and Description
SingleRecordReader(K key, V value)

Method Summary

Modifier and Type	Method and Description
void	close()
K	getCurrentKey()
V	getCurrentValue()
float	getProgress()
void	initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext tac)
boolean	nextKeyValue()

Methods inherited from class java.lang.Object

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

Field Detail

key

private final K key

value

private final V value

providedKey

boolean providedKey

Constructor Detail

SingleRecordReader

SingleRecordReader(K key,
                   V value)

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<K,V>

getCurrentKey

public K getCurrentKey()

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<K,V>

getCurrentValue

public V getCurrentValue()

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<K,V>

getProgress

public float getProgress()

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<K,V>

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
                       org.apache.hadoop.mapreduce.TaskAttemptContext tac)

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<K,V>

nextKeyValue

public boolean nextKeyValue()

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<K,V>