org.apache.hadoop.hive.ql.io
Class NullRowsInputFormat

java.lang.Object
  org.apache.hadoop.hive.ql.io.NullRowsInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>, org.apache.hadoop.mapred.JobConfigurable

Direct Known Subclasses:

OneNullRowInputFormat

public class NullRowsInputFormat
extends Object
implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>, org.apache.hadoop.mapred.JobConfigurable

NullRowsInputFormat outputs null rows, maximum 100.

Nested Class Summary

static class	NullRowsInputFormat.DummyInputSplit
static class	NullRowsInputFormat.NullRowsRecordReader

Constructor Summary

NullRowsInputFormat()

Method Summary

void	configure(org.apache.hadoop.mapred.JobConf job)
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>	getRecordReader(org.apache.hadoop.mapred.InputSplit arg0, org.apache.hadoop.mapred.JobConf arg1, org.apache.hadoop.mapred.Reporter arg2)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf arg0, int arg1)

Methods inherited from class java.lang.Object

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

Constructor Detail

NullRowsInputFormat

public NullRowsInputFormat()

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit arg0,
                                                                                                                                  org.apache.hadoop.mapred.JobConf arg1,
                                                                                                                                  org.apache.hadoop.mapred.Reporter arg2)
                                                                                                                           throws IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf arg0,
                                                       int arg1)
                                                throws IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable