org.apache.pig.piggybank.storage
Class AllLoader.AllReader

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
      extended by org.apache.pig.piggybank.storage.AllLoader.AllReader
All Implemented Interfaces:
Closeable
Enclosing class:
AllLoader

public static class AllLoader.AllReader
extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

This is where the logic is for selecting the correct Loader.


Constructor Summary
AllLoader.AllReader(String udfSignature)
           
 
Method Summary
 void close()
           
 org.apache.hadoop.io.Writable getCurrentKey()
           
 org.apache.hadoop.io.Writable getCurrentValue()
           
 float getProgress()
           
 void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)
           
 boolean nextKeyValue()
           
 LoadFunc prepareLoadFuncForReading(PigSplit split)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AllLoader.AllReader

public AllLoader.AllReader(String udfSignature)
Method Detail

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                       org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)
                throws IOException,
                       InterruptedException
Specified by:
initialize in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
Throws:
IOException
InterruptedException

prepareLoadFuncForReading

public LoadFunc prepareLoadFuncForReading(PigSplit split)
                                   throws IOException
Throws:
IOException

nextKeyValue

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

getCurrentKey

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

getCurrentValue

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

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException
Specified by:
getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
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<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
Throws:
IOException


Copyright © 2007-2012 The Apache Software Foundation