Package 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.

Field Summary

Fields

Modifier and Type	Field	Description
private Connection	conn
private BufferedMutator	m_mutator

Constructor Summary

Constructors

Constructor	Description
TableRecordWriter(BufferedMutator mutator)	Deprecated. since 2.0.0 and will be removed in 3.0.0.
TableRecordWriter(org.apache.hadoop.mapred.JobConf job)	Instantiate a TableRecordWriter with a BufferedMutator for batch writing.

Method Summary

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

Field Details

m_mutator

private BufferedMutator m_mutator

conn

private Connection conn

Constructor Details

TableRecordWriter

@Deprecated
public TableRecordWriter(BufferedMutator mutator)
                  throws IOException

Deprecated.

since 2.0.0 and will be removed in 3.0.0. Please use #TableRecordWriter(JobConf) instead. This version does not clean up connections and will leak connections (removed in 2.0).

Instantiate a TableRecordWriter with the HBase HClient for writing.

Throws:

IOException

See Also:

• HBASE-16774

TableRecordWriter

public TableRecordWriter(org.apache.hadoop.mapred.JobConf job)
                  throws IOException

Instantiate a TableRecordWriter with a BufferedMutator for batch writing.

Throws:

IOException

Method Details

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