com.datasalt.pangool.tuplemr.mapred.lib.input
Class DelegatingInputFormat<K,V>

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<K,V>
      extended by com.datasalt.pangool.tuplemr.mapred.lib.input.DelegatingInputFormat<K,V>

public class DelegatingInputFormat<K,V>
extends org.apache.hadoop.mapreduce.InputFormat<K,V>

An InputFormat that delegates behavior of paths to multiple other InputFormats.

See Also:
PangoolMultipleInputs#addInputPath(Job, Path, InputFormat, org.apache.hadoop.mapreduce.Mapper)

Constructor Summary
DelegatingInputFormat()
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordReader<K,V> 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DelegatingInputFormat

public DelegatingInputFormat()
Method Detail

getSplits

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

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<K,V> 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<K,V>
Throws:
IOException
InterruptedException


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