org.apache.hadoop.hive.ql.io
Class HivePassThroughRecordWriter<K extends org.apache.hadoop.io.WritableComparable<?>,V extends org.apache.hadoop.io.Writable>

java.lang.Object
  org.apache.hadoop.hive.ql.io.HivePassThroughRecordWriter<K,V>

All Implemented Interfaces:

FileSinkOperator.RecordWriter

public class HivePassThroughRecordWriter<K extends org.apache.hadoop.io.WritableComparable<?>,V extends org.apache.hadoop.io.Writable>
extends Object
implements FileSinkOperator.RecordWriter

Constructor Summary

HivePassThroughRecordWriter(org.apache.hadoop.mapred.RecordWriter<K,V> writer)

Method Summary

void	close(boolean abort)
void	write(org.apache.hadoop.io.Writable r)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HivePassThroughRecordWriter

public HivePassThroughRecordWriter(org.apache.hadoop.mapred.RecordWriter<K,V> writer)

Method Detail

write

public void write(org.apache.hadoop.io.Writable r)
           throws IOException

Specified by:

write in interface FileSinkOperator.RecordWriter

Throws:

IOException

close

public void close(boolean abort)
           throws IOException

Specified by:

close in interface FileSinkOperator.RecordWriter

Throws:

IOException