@InterfaceAudience.Public @InterfaceStability.Stable public class TableOutputFormat extends org.apache.hadoop.mapred.FileOutputFormat<ImmutableBytesWritable,Put>
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
static String |
OUTPUT_TABLE
JobConf parameter that specifies the output table
|
| Constructor and Description |
|---|
TableOutputFormat() |
| Modifier and Type | Method and Description |
|---|---|
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job) |
org.apache.hadoop.mapred.RecordWriter |
getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress) |
public static final String OUTPUT_TABLE
public org.apache.hadoop.mapred.RecordWriter getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress)
throws IOException
getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<ImmutableBytesWritable,Put>getRecordWriter in class org.apache.hadoop.mapred.FileOutputFormat<ImmutableBytesWritable,Put>IOExceptionpublic void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job)
throws org.apache.hadoop.fs.FileAlreadyExistsException,
org.apache.hadoop.mapred.InvalidJobConfException,
IOException
checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormat<ImmutableBytesWritable,Put>checkOutputSpecs in class org.apache.hadoop.mapred.FileOutputFormat<ImmutableBytesWritable,Put>org.apache.hadoop.fs.FileAlreadyExistsExceptionorg.apache.hadoop.mapred.InvalidJobConfExceptionIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.