@InterfaceAudience.Public @InterfaceStability.Evolving public class HFileOutputFormat2 extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ImmutableBytesWritable,Cell>
HFiles. Calling write(null,null) will forcibly roll
all HFiles being written.
Using this class as part of a MapReduce job is best done
using configureIncrementalLoad(Job, Table, RegionLocator).
| Modifier and Type | Field and Description |
|---|---|
static String |
DATABLOCK_ENCODING_OVERRIDE_CONF_KEY |
| Constructor and Description |
|---|
HFileOutputFormat2() |
| Modifier and Type | Method and Description |
|---|---|
static void |
configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
org.apache.hadoop.hbase.client.HTable table)
Deprecated.
Use
configureIncrementalLoad(Job, Table, RegionLocator) instead. |
static void |
configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
HTableDescriptor tableDescriptor,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given
table.
|
static void |
configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
Table table,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given
table.
|
static void |
configureIncrementalLoadMap(org.apache.hadoop.mapreduce.Job job,
Table table) |
org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,Cell> |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPathpublic static final String DATABLOCK_ENCODING_OVERRIDE_CONF_KEY
public org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,Cell> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getRecordWriter in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ImmutableBytesWritable,Cell>IOExceptionInterruptedException@Deprecated public static void configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.hbase.client.HTable table) throws IOException
configureIncrementalLoad(Job, Table, RegionLocator) instead.IOExceptionpublic static void configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
Table table,
RegionLocator regionLocator)
throws IOException
IOExceptionpublic static void configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
HTableDescriptor tableDescriptor,
RegionLocator regionLocator)
throws IOException
IOExceptionpublic static void configureIncrementalLoadMap(org.apache.hadoop.mapreduce.Job job,
Table table)
throws IOException
IOExceptionCopyright © 2007–2016 The Apache Software Foundation. All rights reserved.