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,
StoreFuncDecorator storeDecorator,
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, StoreFuncDecorator storeDecorator, org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode) throws IOException
IOException
public void write(org.apache.hadoop.io.WritableComparable key, Tuple value) throws IOException, InterruptedException
write
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
IOException
InterruptedException
RecordWriter.write(Object, Object)
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext) throws IOException, InterruptedException
close
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
IOException
InterruptedException
Copyright © 2007-2017 The Apache Software Foundation