com.datasalt.pangool.tuplemr.mapred.lib.input
Class HadoopInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat
      extended by com.datasalt.pangool.tuplemr.mapred.lib.input.HadoopInputFormat
All Implemented Interfaces:
Serializable, org.apache.hadoop.conf.Configurable

public class HadoopInputFormat
extends org.apache.hadoop.mapreduce.InputFormat
implements Serializable, org.apache.hadoop.conf.Configurable

See Also:
Serialized Form

Constructor Summary
HadoopInputFormat(Class<? extends org.apache.hadoop.mapreduce.InputFormat> clazz)
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordReader createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 org.apache.hadoop.conf.Configuration getConf()
           
 List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
           
 void setConf(org.apache.hadoop.conf.Configuration conf)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HadoopInputFormat

public HadoopInputFormat(Class<? extends org.apache.hadoop.mapreduce.InputFormat> clazz)
Method Detail

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                       throws IOException,
                                                              InterruptedException
Specified by:
getSplits in class org.apache.hadoop.mapreduce.InputFormat
Throws:
IOException
InterruptedException

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                   org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                            throws IOException,
                                                                   InterruptedException
Specified by:
createRecordReader in class org.apache.hadoop.mapreduce.InputFormat
Throws:
IOException
InterruptedException

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)
Specified by:
setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()
Specified by:
getConf in interface org.apache.hadoop.conf.Configurable


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.