org.apache.hadoop.hbase.mapreduce

Class NMapInputFormat

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.NMapInputFormat

public class NMapInputFormat
extends <any>

Input format that creates a configurable number of map tasks each provided with a single row of NullWritables. This can be useful when trying to write mappers which don't have any real input (eg when the mapper is simply producing random data as output)

Constructor Summary

Constructors

Constructor and Description
NMapInputFormat()

Method Summary

Modifier and Type	Method and Description
<any>	createRecordReader(InputSplit split, TaskAttemptContext tac)
static int	getNumMapTasks(Configuration conf)
List<InputSplit>	getSplits(JobContext context)
static void	setNumMapTasks(Configuration conf, int numTasks)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NMapInputFormat

public NMapInputFormat()

Method Detail

createRecordReader

public <any> createRecordReader(InputSplit split,
                                TaskAttemptContext tac)
                         throws IOException,
                                InterruptedException

Throws:

IOException

InterruptedException

getSplits

public List<InputSplit> getSplits(JobContext context)
                           throws IOException,
                                  InterruptedException

Throws:

IOException

InterruptedException

setNumMapTasks

public static void setNumMapTasks(Configuration conf,
                                  int numTasks)

getNumMapTasks

public static int getNumMapTasks(Configuration conf)