org.apache.pig.impl.io

Class TFileRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>

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

Constructors

Constructor and Description
TFileRecordWriter(org.apache.hadoop.fs.Path file, String codec, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
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