org.apache.hadoop.hbase.mapreduce
Class LoadIncrementalHFiles
java.lang.Object
org.apache.hadoop.conf.Configured
org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles
- All Implemented Interfaces:
- org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool
public class LoadIncrementalHFiles
- extends org.apache.hadoop.conf.Configured
- implements org.apache.hadoop.util.Tool
Tool to load the output of HFileOutputFormat into an existing table.
- See Also:
usage()
Method Summary |
void |
doBulkLoad(org.apache.hadoop.fs.Path hfofDir,
HTable table)
Perform a bulk load of the given directory into the given
pre-existing table. |
static void |
main(String[] args)
|
int |
run(String[] args)
|
Methods inherited from class org.apache.hadoop.conf.Configured |
getConf, setConf |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.hadoop.conf.Configurable |
getConf, setConf |
NAME
public static String NAME
LoadIncrementalHFiles
public LoadIncrementalHFiles(org.apache.hadoop.conf.Configuration conf)
LoadIncrementalHFiles
public LoadIncrementalHFiles()
doBulkLoad
public void doBulkLoad(org.apache.hadoop.fs.Path hfofDir,
HTable table)
throws TableNotFoundException,
IOException
- Perform a bulk load of the given directory into the given
pre-existing table.
- Parameters:
hfofDir
- the directory that was provided as the output path
of a job using HFileOutputFormattable
- the table to load into
- Throws:
TableNotFoundException
- if table does not yet exist
IOException
run
public int run(String[] args)
throws Exception
- Specified by:
run
in interface org.apache.hadoop.util.Tool
- Throws:
Exception
main
public static void main(String[] args)
throws Exception
- Throws:
Exception
Copyright © 2011 The Apache Software Foundation. All Rights Reserved.