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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader
      extended by org.apache.pig.piggybank.storage.XMLLoader.XMLFileRecordReader
All Implemented Interfaces:
Closeable
Enclosing class:
XMLLoader

public static class XMLLoader.XMLFileRecordReader
extends org.apache.hadoop.mapreduce.RecordReader


Constructor Summary
XMLLoader.XMLFileRecordReader(String recordIdentifier)
           
 
Method Summary
 void close()
           
 Object getCurrentKey()
           
 Object getCurrentValue()
           
 float getProgress()
           
 void initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 boolean nextKeyValue()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

XMLLoader.XMLFileRecordReader

public XMLLoader.XMLFileRecordReader(String recordIdentifier)
Method Detail

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit,
                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
                       InterruptedException
Specified by:
initialize in class org.apache.hadoop.mapreduce.RecordReader
Throws:
IOException
InterruptedException

close

public void close()
           throws IOException
Specified by:
close in interface Closeable
Specified by:
close in class org.apache.hadoop.mapreduce.RecordReader
Throws:
IOException

getCurrentKey

public Object getCurrentKey()
                     throws IOException,
                            InterruptedException
Specified by:
getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader
Throws:
IOException
InterruptedException

getCurrentValue

public Object getCurrentValue()
                       throws IOException,
                              InterruptedException
Specified by:
getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader
Throws:
IOException
InterruptedException

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException
Specified by:
getProgress in class org.apache.hadoop.mapreduce.RecordReader
Throws:
IOException
InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws IOException,
                            InterruptedException
Specified by:
nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader
Throws:
IOException
InterruptedException


Copyright © ${year} The Apache Software Foundation