org.apache.pig.piggybank.storage
Class XMLLoader.XMLFileInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.input.FileInputFormat
          extended by org.apache.pig.piggybank.storage.XMLLoader.XMLFileInputFormat
Enclosing class:
XMLLoader

public static class XMLLoader.XMLFileInputFormat
extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
org.apache.hadoop.mapreduce.lib.input.FileInputFormat.Counter
 
Constructor Summary
XMLLoader.XMLFileInputFormat(String recordIdentifier)
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordReader createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
protected  boolean isSplitable(org.apache.hadoop.mapreduce.JobContext context, org.apache.hadoop.fs.Path filename)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, listStatus, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

XMLLoader.XMLFileInputFormat

public XMLLoader.XMLFileInputFormat(String recordIdentifier)
Method Detail

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

isSplitable

protected boolean isSplitable(org.apache.hadoop.mapreduce.JobContext context,
                              org.apache.hadoop.fs.Path filename)
Overrides:
isSplitable in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat


Copyright © 2007-2012 The Apache Software Foundation