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
Modifier and TypeFieldDescriptionprivate int
private org.apache.hadoop.io.Text
private int
static final String
private org.apache.hadoop.io.NullWritable
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
org.apache.hadoop.io.Text
org.apache.hadoop.io.NullWritable
float
void
initialize
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) boolean
-
Field Details
-
numRecordsToCreate
-
createdRecords
-
key
-
value
-
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 classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,
org.apache.hadoop.io.NullWritable> - Throws:
IOException
InterruptedException
-
nextKeyValue
- Specified by:
nextKeyValue
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,
org.apache.hadoop.io.NullWritable>
-
getCurrentKey
- Specified by:
getCurrentKey
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,
org.apache.hadoop.io.NullWritable>
-
getCurrentValue
- Specified by:
getCurrentValue
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,
org.apache.hadoop.io.NullWritable>
-
getProgress
- Specified by:
getProgress
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,
org.apache.hadoop.io.NullWritable> - Throws:
IOException
InterruptedException
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,
org.apache.hadoop.io.NullWritable> - Throws:
IOException
-