public static class PigOutputFormat.PigRecordWriter extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
Constructor and Description |
---|
PigOutputFormat.PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter,
StoreFuncInterface sFunc,
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.Mode mode) |
public PigOutputFormat.PigRecordWriter(org.apache.hadoop.mapreduce.RecordWriter wrappedWriter, StoreFuncInterface sFunc, 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-2012 The Apache Software Foundation