public class BulkDataGeneratorInputFormat extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>
Modifier and Type | Class and Description |
---|---|
private static class |
BulkDataGeneratorInputFormat.FakeInputSplit
Dummy input split to be used by
BulkDataGeneratorRecordReader |
Modifier and Type | Field and Description |
---|---|
static String |
MAPPER_TASK_COUNT_KEY |
Constructor and Description |
---|
BulkDataGeneratorInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext job) |
public static final String MAPPER_TASK_COUNT_KEY
public BulkDataGeneratorInputFormat()
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext job) throws IOException
getSplits
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>
IOException
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>
IOException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.