org.apache.pig.impl.io
Class InterRecordWriter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
      extended by org.apache.pig.impl.io.InterRecordWriter

public class InterRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>

A record reader used to write data compatible with InterRecordWriter It uses the default InterSedes object for serialization.


Field Summary
static int RECORD_1
           
static int RECORD_2
           
static int RECORD_3
           
 
Constructor Summary
InterRecordWriter(DataOutputStream out)
           
 
Method Summary
 void close(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
           
 void write(org.apache.hadoop.io.WritableComparable wc, Tuple t)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

RECORD_1

public static final int RECORD_1
See Also:
Constant Field Values

RECORD_2

public static final int RECORD_2
See Also:
Constant Field Values

RECORD_3

public static final int RECORD_3
See Also:
Constant Field Values
Constructor Detail

InterRecordWriter

public InterRecordWriter(DataOutputStream out)
Method Detail

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
           throws IOException,
                  InterruptedException
Specified by:
close in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
Throws:
IOException
InterruptedException

write

public void write(org.apache.hadoop.io.WritableComparable wc,
                  Tuple t)
           throws IOException,
                  InterruptedException
Specified by:
write in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>
Throws:
IOException
InterruptedException


Copyright © 2007-2012 The Apache Software Foundation