org.apache.hadoop.hbase.mapreduce

Class TableOutputFormat.TableRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>

org.apache.hadoop.hbase.mapreduce.TableOutputFormat.TableRecordWriter

Enclosing class:

TableOutputFormat<KEY>

protected class TableOutputFormat.TableRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>

Writes the reducer output to an HBase table.

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	connection
private BufferedMutator	mutator

Constructor Summary

Constructors

Constructor and Description
TableRecordWriter()

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context) Closes the writer, in this case flush table commits.
void	write(KEY key, Mutation value) Writes a key/value pair into the table.

Methods inherited from class java.lang.Object

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

Field Detail

connection

private Connection connection

mutator

private BufferedMutator mutator

Constructor Detail

TableRecordWriter

public TableRecordWriter()
                  throws IOException

Throws:

IOException

Method Detail

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws IOException

Closes the writer, in this case flush table commits.

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>

Parameters:

context - The context.

Throws:

IOException - When closing the writer fails.

See Also:

RecordWriter.close(TaskAttemptContext)

write

public void write(KEY key,
                  Mutation value)
           throws IOException

Writes a key/value pair into the table.

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<KEY,Mutation>

Parameters:

key - The key.

value - The value.

Throws:

IOException - When writing fails.

See Also:

RecordWriter.write(Object, Object)