Package org.apache.hadoop.hbase.mapreduce

Class CopyTable

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.mapreduce.CopyTable

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

@Public
public class CopyTable
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

Tool used to copy a table to another one which can be on a different setup. It is also configurable with a start and time as well as a specification of the region server implementation if different from the local cluster.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	allCells
(package private) int	batch
(package private) boolean	bulkload
(package private) org.apache.hadoop.fs.Path	bulkloadDir
(package private) int	cacheRow
(package private) String	dstTableName
(package private) long	endTime
(package private) String	families
private static final String	JOB_NAME_CONF_KEY
private static final org.slf4j.Logger	LOG
(package private) static final String	NAME
(package private) String	peerAddress	Deprecated. Since 3.0.0, will be removed in 4.0.0.
(package private) URI	peerUri
(package private) boolean	readingSnapshot
(package private) static boolean	shuffle
(package private) String	snapshot
(package private) String	startRow
(package private) long	startTime
(package private) String	stopRow
(package private) String	tableName
(package private) int	versions

Constructor Summary

Constructors

Constructor	Description
CopyTable()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.mapreduce.Job	createSubmittableJob(String[] args)	Sets up the actual job.
private boolean	doCommandLine(String[] args)
private org.apache.hadoop.fs.Path	generateUniqTempDir(boolean withDirCreated)
private void	initCopyTableMapperJob(org.apache.hadoop.mapreduce.Job job, Scan scan)
static void	main(String[] args)	Main entry point.
private static void	printUsage(String errorMsg)
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

Field Details

LOG

private static final org.slf4j.Logger LOG

NAME

static final String NAME

See Also:

• Constant Field Values

startTime

long startTime

endTime

long endTime

batch

int batch

cacheRow

int cacheRow

versions

int versions

tableName

String tableName

startRow

String startRow

stopRow

String stopRow

dstTableName

String dstTableName

peerUri

URI peerUri

peerAddress

@Deprecated
String peerAddress

Deprecated.

Since 3.0.0, will be removed in 4.0.0. Use peerUri instead.

families

String families

allCells

boolean allCells

shuffle

static boolean shuffle

bulkload

boolean bulkload

bulkloadDir

org.apache.hadoop.fs.Path bulkloadDir

readingSnapshot

boolean readingSnapshot

snapshot

String snapshot

JOB_NAME_CONF_KEY

private static final String JOB_NAME_CONF_KEY

See Also:

• Constant Field Values

Constructor Details

CopyTable

public CopyTable()

Method Details

generateUniqTempDir

private org.apache.hadoop.fs.Path generateUniqTempDir(boolean withDirCreated)
                                               throws IOException

Throws:

IOException

initCopyTableMapperJob

private void initCopyTableMapperJob(org.apache.hadoop.mapreduce.Job job,
 Scan scan)
                             throws IOException

Throws:

IOException

createSubmittableJob

public org.apache.hadoop.mapreduce.Job createSubmittableJob(String[] args)
                                                     throws IOException

Sets up the actual job.

Parameters:

args - The command line parameters.

Returns:

The newly created job.

Throws:

IOException - When setting up the job fails.

printUsage

private static void printUsage(String errorMsg)

doCommandLine

private boolean doCommandLine(String[] args)

main

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

Main entry point.

Parameters:

args - The command line parameters.

Throws:

Exception - When running the job fails.

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception