MultithreadedTableMapper.SubMapRecordReader (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
- - org.apache.hadoop.hbase.mapreduce.MultithreadedTableMapper.SubMapRecordReader

All Implemented Interfaces:: Closeable, AutoCloseable

Enclosing class:: MultithreadedTableMapper<K2,V2>

private class MultithreadedTableMapper.SubMapRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

Field Summary

Fields
Modifier and Type Field and Description

private org.apache.hadoop.conf.Configuration conf

private ImmutableBytesWritable key

private Result value

Fields
Modifier and Type	Field and Description
`private org.apache.hadoop.conf.Configuration`	`conf`
`private ImmutableBytesWritable`	`key`
`private Result`	`value`

Constructor Summary

Constructors
Modifier Constructor and Description

private MultithreadedTableMapper.SubMapRecordReader()

Constructors
Modifier	Constructor and Description
`private`	`MultithreadedTableMapper.SubMapRecordReader()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`close()`
`ImmutableBytesWritable`	`getCurrentKey()`
`Result`	`getCurrentValue()`
`float`	`getProgress()`
`void`	`initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)`
`boolean`	`nextKeyValue()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - key
```
private ImmutableBytesWritable key
```
  - value
```
private Result value
```
  - conf
```
private org.apache.hadoop.conf.Configuration conf
```
- Constructor Detail
  - MultithreadedTableMapper.SubMapRecordReader
```
private MultithreadedTableMapper.SubMapRecordReader()
```
- Method Detail
  - close
```
public void close()
           throws IOException
```
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
    
    Throws:
    
    IOException
  - getProgress
```
public float getProgress()
                  throws IOException,
                         InterruptedException
```
    Specified by:
    
    getProgress in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
    
    Throws:
    
    IOException
    
    InterruptedException
  - initialize
```
public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
              org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
                       InterruptedException
```
    Specified by:
    
    initialize in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
    
    Throws:
    
    IOException
    
    InterruptedException
  - nextKeyValue
```
public boolean nextKeyValue()
                     throws IOException,
                            InterruptedException
```
    Specified by:
    
    nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
    
    Throws:
    
    IOException
    
    InterruptedException
  - getCurrentKey
```
public ImmutableBytesWritable getCurrentKey()
```
    Specified by:
    
    getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
  - getCurrentValue
```
public Result getCurrentValue()
```
    Specified by:
    
    getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

Class MultithreadedTableMapper.SubMapRecordReader

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

key

value

conf

Constructor Detail

MultithreadedTableMapper.SubMapRecordReader

Method Detail

close

getProgress

initialize

nextKeyValue

getCurrentKey

getCurrentValue