org.apache.hadoop.hbase.backup.mapreduce

Class HFileSplitter

java.lang.Object

Configured

org.apache.hadoop.hbase.backup.mapreduce.HFileSplitter

@InterfaceAudience.Private
public class HFileSplitter
extends Configured

A tool to split HFiles into new region boundaries as a MapReduce job. The tool generates HFiles for later bulk importing.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BULK_OUTPUT_CONF_KEY
static java.lang.String	TABLE_MAP_KEY
static java.lang.String	TABLES_KEY

Constructor Summary

Constructors

Modifier	Constructor and Description
	HFileSplitter()
protected	HFileSplitter(Configuration c)

Method Summary

Modifier and Type	Method and Description
Job	createSubmittableJob(java.lang.String[] args) Sets up the actual job.
static void	main(java.lang.String[] args) Main entry point.
int	run(java.lang.String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BULK_OUTPUT_CONF_KEY

public static final java.lang.String BULK_OUTPUT_CONF_KEY

See Also:

Constant Field Values

TABLES_KEY

public static final java.lang.String TABLES_KEY

See Also:

Constant Field Values

TABLE_MAP_KEY

public static final java.lang.String TABLE_MAP_KEY

See Also:

Constant Field Values

Constructor Detail

HFileSplitter

public HFileSplitter()

HFileSplitter

protected HFileSplitter(Configuration c)

Method Detail

createSubmittableJob

public Job createSubmittableJob(java.lang.String[] args)
                         throws java.io.IOException

Sets up the actual job.

Parameters:

args - The command line parameters.

Returns:

The newly created job.

Throws:

java.io.IOException - When setting up the job fails.

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Main entry point.

Parameters:

args - The command line parameters.

Throws:

java.lang.Exception - When running the job fails.

run

public int run(java.lang.String[] args)
        throws java.lang.Exception

Throws:

java.lang.Exception