org.apache.pig.impl.io
Class BinStorageRecordWriter

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

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


Field Summary
static int RECORD_1
           
static int RECORD_2
           
static int RECORD_3
           
 
Constructor Summary
BinStorageRecordWriter(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

BinStorageRecordWriter

public BinStorageRecordWriter(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