Class MultithreadedTableMapper.SubMapRecordReader
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
Modifier and TypeFieldDescriptionprivate org.apache.hadoop.conf.Configuration
private ImmutableBytesWritable
private Result
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
float
void
initialize
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) boolean
-
Field Details
-
key
-
value
-
conf
-
-
Constructor Details
-
SubMapRecordReader
private SubMapRecordReader()
-
-
Method Details
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
-
getProgress
- Specified by:
getProgress
in classorg.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 classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
nextKeyValue
- Specified by:
nextKeyValue
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
getCurrentKey
- Specified by:
getCurrentKey
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result>
-
getCurrentValue
- Specified by:
getCurrentValue
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result>
-