org.apache.hadoop.streaming
Class AutoInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapred.FileInputFormat
      extended by org.apache.hadoop.streaming.AutoInputFormat
All Implemented Interfaces:
org.apache.hadoop.mapred.InputFormat

public class AutoInputFormat
extends org.apache.hadoop.mapred.FileInputFormat

An InputFormat that tries to deduce the types of the input files automatically. It can currently handle text and sequence files.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapred.FileInputFormat
org.apache.hadoop.mapred.FileInputFormat.Counter
 
Field Summary
 
Fields inherited from class org.apache.hadoop.mapred.FileInputFormat
INPUT_DIR_RECURSIVE, LOG, NUM_INPUT_FILES
 
Constructor Summary
AutoInputFormat()
           
 
Method Summary
 void configure(org.apache.hadoop.mapred.JobConf job)
           
 org.apache.hadoop.mapred.RecordReader getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
           
 
Methods inherited from class org.apache.hadoop.mapred.FileInputFormat
addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, getSplits, isSplitable, listStatus, makeSplit, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AutoInputFormat

public AutoInputFormat()
Method Detail

configure

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

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 IOException
Specified by:
getRecordReader in interface org.apache.hadoop.mapred.InputFormat
Specified by:
getRecordReader in class org.apache.hadoop.mapred.FileInputFormat
Throws:
IOException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.