org.apache.hadoop.hbase.mapred
Class TableOutputFormat.TableRecordWriter

java.lang.Object
  extended by org.apache.hadoop.hbase.mapred.TableOutputFormat.TableRecordWriter
All Implemented Interfaces:
org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>
Enclosing class:
TableOutputFormat

protected static class TableOutputFormat.TableRecordWriter
extends Object
implements org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>

Convert Reduce output (key, value) to (HStoreKey, KeyedDataArrayWritable) and write to an HBase table


Constructor Summary
TableOutputFormat.TableRecordWriter(HTable table)
          Instantiate a TableRecordWriter with the HBase HClient for writing.
 
Method Summary
 void close(org.apache.hadoop.mapred.Reporter reporter)
           
 void write(ImmutableBytesWritable key, Put value)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TableOutputFormat.TableRecordWriter

public TableOutputFormat.TableRecordWriter(HTable table)
Instantiate a TableRecordWriter with the HBase HClient for writing.

Parameters:
table -
Method Detail

close

public void close(org.apache.hadoop.mapred.Reporter reporter)
           throws IOException
Specified by:
close in interface org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>
Throws:
IOException

write

public void write(ImmutableBytesWritable key,
                  Put value)
           throws IOException
Specified by:
write in interface org.apache.hadoop.mapred.RecordWriter<ImmutableBytesWritable,Put>
Throws:
IOException


Copyright © 2011 The Apache Software Foundation. All Rights Reserved.