org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class PigOutputFormat.PigRecordWriter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.PigRecordWriter
Enclosing class:
PigOutputFormat

public static class PigOutputFormat.PigRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>

Wrapper class which will delegate calls to the actual RecordWriter - this should only get called in the single store case.


Constructor Summary
PigOutputFormat.PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter, StoreFuncInterface sFunc, org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode)
           
 
Method Summary
 void close(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)
           
 void write(org.apache.hadoop.io.WritableComparable key, Tuple value)
          We only care about the values, so we are going to skip the keys when we write.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PigOutputFormat.PigRecordWriter

public PigOutputFormat.PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter,
                                       StoreFuncInterface sFunc,
                                       org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode)
                                throws IOException
Throws:
IOException
Method Detail

write

public void write(org.apache.hadoop.io.WritableComparable key,
                  Tuple value)
           throws IOException,
                  InterruptedException
We only care about the values, so we are going to skip the keys when we write.

Specified by:
write in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
Throws:
IOException
InterruptedException
See Also:
RecordWriter.write(Object, Object)

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)
           throws IOException,
                  InterruptedException
Specified by:
close in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
Throws:
IOException
InterruptedException


Copyright © ${year} The Apache Software Foundation