@InterfaceAudience.Public @InterfaceStability.Evolving public class HFileOutputFormat2 extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ImmutableBytesWritable,Cell>
HFile
s. 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 |
static String |
LOCALITY_SENSITIVE_CONF_KEY
Keep locality while generating HFiles for bulkload.
|
Constructor and Description |
---|
HFileOutputFormat2() |
Modifier and Type | Method and Description |
---|---|
static void |
configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
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, setOutputPath
public static final String DATABLOCK_ENCODING_OVERRIDE_CONF_KEY
public static final String LOCALITY_SENSITIVE_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>
IOException
InterruptedException
@Deprecated public static void configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job, HTable table) throws IOException
configureIncrementalLoad(Job, Table, RegionLocator)
instead.IOException
public static void configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job, Table table, RegionLocator regionLocator) throws IOException
IOException
public static void configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job, HTableDescriptor tableDescriptor, RegionLocator regionLocator) throws IOException
IOException
public static void configureIncrementalLoadMap(org.apache.hadoop.mapreduce.Job job, Table table) throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.