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

java.lang.Object
  org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Writable>
      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