org.apache.pig.impl.io
Class TFileRecordWriter

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

public class TFileRecordWriter
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.


Constructor Summary
TFileRecordWriter(org.apache.hadoop.fs.Path file, String codec, org.apache.hadoop.conf.Configuration conf)
           
 
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
 

Constructor Detail

TFileRecordWriter

public TFileRecordWriter(org.apache.hadoop.fs.Path file,
                         String codec,
                         org.apache.hadoop.conf.Configuration conf)
                  throws IOException
Throws:
IOException
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