org.apache.pig.piggybank.storage.hiverc
Class HiveRCOutputFormat.Writer

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Writable>
      extended by org.apache.pig.piggybank.storage.hiverc.HiveRCOutputFormat.Writer
Enclosing class:
HiveRCOutputFormat

protected static class HiveRCOutputFormat.Writer
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Writable>

RecordWriter wrapper around an RCFile.Writer


Constructor Summary
protected HiveRCOutputFormat.Writer(HiveRCOutputFormat outputFormat, org.apache.hadoop.mapreduce.TaskAttemptContext job, org.apache.hadoop.io.Text columnMetadata)
           
 
Method Summary
 void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 void write(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.io.Writable value)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HiveRCOutputFormat.Writer

protected HiveRCOutputFormat.Writer(HiveRCOutputFormat outputFormat,
                                    org.apache.hadoop.mapreduce.TaskAttemptContext job,
                                    org.apache.hadoop.io.Text columnMetadata)
                             throws IOException
Throws:
IOException
Method Detail

close

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

write

public void write(org.apache.hadoop.io.NullWritable key,
                  org.apache.hadoop.io.Writable value)
           throws IOException,
                  InterruptedException
Specified by:
write in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Writable>
Throws:
IOException
InterruptedException


Copyright © 2007-2012 The Apache Software Foundation