org.apache.hadoop.hbase.mapred

Class TableOutputFormat

java.lang.Object

<any>

org.apache.hadoop.hbase.mapred.TableOutputFormat

public class TableOutputFormat
extends <any>

Convert Map/Reduce output and write it to an HBase table

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	TableOutputFormat.TableRecordWriter Convert Reduce output (key, value) to (HStoreKey, KeyedDataArrayWritable) and write to an HBase table.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	OUTPUT_TABLE JobConf parameter that specifies the output table

Constructor Summary

Constructors

Constructor and Description
TableOutputFormat()

Method Summary

Modifier and Type	Method and Description
void	checkOutputSpecs(FileSystem ignored, JobConf job)
RecordWriter	getRecordWriter(FileSystem ignored, JobConf job, java.lang.String name, Progressable progress) Creates a new record writer.

Methods inherited from class java.lang.Object

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

Field Detail

OUTPUT_TABLE

public static final java.lang.String OUTPUT_TABLE

JobConf parameter that specifies the output table

See Also:

Constant Field Values

Constructor Detail

TableOutputFormat

public TableOutputFormat()

Method Detail

getRecordWriter

public RecordWriter getRecordWriter(FileSystem ignored,
                                    JobConf job,
                                    java.lang.String name,
                                    Progressable progress)
                             throws java.io.IOException

Creates a new record writer. Be aware that the baseline javadoc gives the impression that there is a single RecordWriter per job but in HBase, it is more natural if we give you a new RecordWriter per call of this method. You must close the returned RecordWriter when done. Failure to do so will drop writes.

Parameters:

ignored - Ignored filesystem

job - Current JobConf

name - Name of the job

progress -

Returns:

The newly created writer instance.

Throws:

java.io.IOException - When creating the writer fails.

checkOutputSpecs

public void checkOutputSpecs(FileSystem ignored,
                             JobConf job)
                      throws FileAlreadyExistsException,
                             InvalidJobConfException,
                             java.io.IOException

Throws:

FileAlreadyExistsException

InvalidJobConfException

java.io.IOException