public class SampleUploader extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool
This is EXAMPLE code. You will need to change it to work for your context.
TableReducer to put the data into HBase. Change the InputFormat
to suit your data. In this example, we are importing a CSV file.
The table and columnfamily we're to insert into must preexist.
There is no reducer in this example as it is not necessary and adds significant overhead. If you need to do any massaging of data before inserting into HBase, you can do this in the map as well.
Do the following to start the MR job:
./bin/hadoop org.apache.hadoop.hbase.mapreduce.SampleUploader /tmp/input.csv TABLE_NAME
This code was written against HBase 0.21 trunk.
|Constructor and Description|
|Modifier and Type||Method and Description|
Main entry point.
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static org.apache.hadoop.mapreduce.Job configureJob(org.apache.hadoop.conf.Configuration conf, String args) throws IOException
otherArgs- The command line parameters after ToolRunner handles standard.
Exception- When running the job fails.
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.