org.apache.hadoop.hbase.mapred

Class TableOutputFormat.TableRecordWriter

java.lang.Object

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

Constructors

Constructor and Description
TableOutputFormat.TableRecordWriter(HTable table) Instantiate a TableRecordWriter with the HBase HClient for writing.

Method Summary

Methods

Modifier and Type	Method and Description
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