@InterfaceAudience.Public @InterfaceStability.Evolving public class HFileOutputFormat2 extends <any>
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 java.lang.String |
DATABLOCK_ENCODING_OVERRIDE_CONF_KEY |
Constructor and Description |
---|
HFileOutputFormat2() |
Modifier and Type | Method and Description |
---|---|
static void |
configureIncrementalLoad(Job job,
HTable table)
Deprecated.
Use
configureIncrementalLoad(Job, Table, RegionLocator) instead. |
static void |
configureIncrementalLoad(Job job,
HTableDescriptor tableDescriptor,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given
table.
|
static void |
configureIncrementalLoad(Job job,
Table table,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given
table.
|
static void |
configureIncrementalLoadMap(Job job,
Table table) |
<any> |
getRecordWriter(TaskAttemptContext context) |
public static final java.lang.String DATABLOCK_ENCODING_OVERRIDE_CONF_KEY
public <any> getRecordWriter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
@Deprecated public static void configureIncrementalLoad(Job job, HTable table) throws java.io.IOException
configureIncrementalLoad(Job, Table, RegionLocator)
instead.java.io.IOException
public static void configureIncrementalLoad(Job job, Table table, RegionLocator regionLocator) throws java.io.IOException
java.io.IOException
public static void configureIncrementalLoad(Job job, HTableDescriptor tableDescriptor, RegionLocator regionLocator) throws java.io.IOException
java.io.IOException
public static void configureIncrementalLoadMap(Job job, Table table) throws java.io.IOException
java.io.IOException