org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Class PigOutputFormat.PigRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>

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

Constructors

Constructor and Description
PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter, StoreFuncDecorator storeDecorator, org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode)

Method Summary

Modifier and Type	Method and Description
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

PigRecordWriter

public PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter,
                       StoreFuncDecorator storeDecorator,
                       org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

write

public void write(org.apache.hadoop.io.WritableComparable key,
                  Tuple value)
           throws java.io.IOException,
                  java.lang.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:

java.io.IOException

java.lang.InterruptedException

See Also:

RecordWriter.write(Object, Object)

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)
           throws java.io.IOException,
                  java.lang.InterruptedException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>

Throws:

java.io.IOException

java.lang.InterruptedException