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 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