com.nhncorp.neptune.parallel.hadoop
Class SimpleInputFormat

java.lang.Object
  com.nhncorp.neptune.parallel.hadoop.SimpleInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat

public class SimpleInputFormat
extends java.lang.Object
implements org.apache.hadoop.mapred.InputFormat

Constructor Summary

SimpleInputFormat()

Method Summary

org.apache.hadoop.mapred.RecordReader	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)
void	validateInput(org.apache.hadoop.mapred.JobConf job)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleInputFormat

public SimpleInputFormat()

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                             org.apache.hadoop.mapred.JobConf job,
                                                             org.apache.hadoop.mapred.Reporter reporter)
                                                      throws java.io.IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat

Throws:

java.io.IOException

validateInput

public void validateInput(org.apache.hadoop.mapred.JobConf job)
                   throws java.io.IOException

Specified by:

validateInput in interface org.apache.hadoop.mapred.InputFormat

Throws:

java.io.IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job,
                                                       int numSplits)
                                                throws java.io.IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat

Throws:

java.io.IOException