public static class PigOutputFormat.PigRecordWriter extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
Constructor and Description |
---|
PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter,
StoreFuncInterface sFunc,
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode) |
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.
|
public PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter, StoreFuncInterface sFunc, org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode) throws java.io.IOException
java.io.IOException
public void write(org.apache.hadoop.io.WritableComparable key, Tuple value) throws java.io.IOException, java.lang.InterruptedException
write
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
java.io.IOException
java.lang.InterruptedException
RecordWriter.write(Object, Object)
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext) throws java.io.IOException, java.lang.InterruptedException
close
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
java.io.IOException
java.lang.InterruptedException
Copyright © 2007-2012 The Apache Software Foundation