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

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

Enclosing class:

XMLLoader

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

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)

Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat

addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, 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