Package org.apache.hadoop.hbase.util.bulkdatagenerator

Class BulkDataGeneratorRecordReader

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

org.apache.hadoop.hbase.util.bulkdatagenerator.BulkDataGeneratorRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class BulkDataGeneratorRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

Field Summary

Fields

Modifier and Type	Field	Description
private int	createdRecords
private org.apache.hadoop.io.Text	key
private int	numRecordsToCreate
static final String	RECORDS_PER_MAPPER_TASK_KEY
private org.apache.hadoop.io.NullWritable	value

Constructor Summary

Constructors

Constructor	Description
BulkDataGeneratorRecordReader()

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.hadoop.io.Text	getCurrentKey()
org.apache.hadoop.io.NullWritable	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 Details

numRecordsToCreate

private int numRecordsToCreate

createdRecords

private int createdRecords

key

private org.apache.hadoop.io.Text key

value

private org.apache.hadoop.io.NullWritable value

RECORDS_PER_MAPPER_TASK_KEY

public static final String RECORDS_PER_MAPPER_TASK_KEY

Constructor Details

BulkDataGeneratorRecordReader

public BulkDataGeneratorRecordReader()

Method Details

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<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException

nextKeyValue

public boolean nextKeyValue()

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

getCurrentKey

public org.apache.hadoop.io.Text getCurrentKey()

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

getCurrentValue

public org.apache.hadoop.io.NullWritable getCurrentValue()

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

getProgress

public float getProgress()
                  throws IOException,
InterruptedException

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

Throws:

IOException