Package org.apache.hadoop.hbase.mapreduce

Class SyncTable

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.mapreduce.SyncTable

All Implemented Interfaces:

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

@Private
public class SyncTable
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SyncTable.SyncMapper

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.apache.hadoop.mapreduce.Counters	counters
(package private) static final String	DO_DELETES_CONF_KEY
(package private) static final String	DO_PUTS_CONF_KEY
(package private) boolean	doDeletes
(package private) boolean	doPuts
(package private) static final String	DRY_RUN_CONF_KEY
(package private) boolean	dryRun
(package private) static final String	IGNORE_TIMESTAMPS
(package private) boolean	ignoreTimestamps
private static final org.slf4j.Logger	LOG
private static final int	NUM_ARGS
(package private) static final String	SOURCE_HASH_DIR_CONF_KEY
(package private) static final String	SOURCE_TABLE_CONF_KEY
(package private) static final String	SOURCE_ZK_CLUSTER_CONF_KEY
(package private) org.apache.hadoop.fs.Path	sourceHashDir
(package private) String	sourceTableName
(package private) String	sourceZkCluster
(package private) static final String	TARGET_TABLE_CONF_KEY
(package private) static final String	TARGET_ZK_CLUSTER_CONF_KEY
(package private) String	targetTableName
(package private) String	targetZkCluster

Constructor Summary

Constructors

Constructor	Description
SyncTable(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.mapreduce.Job	createSubmittableJob(String[] args)
private boolean	doCommandLine(String[] args)
private void	initCredentialsForHBase(String zookeeper, org.apache.hadoop.mapreduce.Job job)
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

SOURCE_HASH_DIR_CONF_KEY

static final String SOURCE_HASH_DIR_CONF_KEY

See Also:

• Constant Field Values

SOURCE_TABLE_CONF_KEY

static final String SOURCE_TABLE_CONF_KEY

See Also:

• Constant Field Values

TARGET_TABLE_CONF_KEY

static final String TARGET_TABLE_CONF_KEY

See Also:

• Constant Field Values

SOURCE_ZK_CLUSTER_CONF_KEY

static final String SOURCE_ZK_CLUSTER_CONF_KEY

See Also:

• Constant Field Values

TARGET_ZK_CLUSTER_CONF_KEY

static final String TARGET_ZK_CLUSTER_CONF_KEY

See Also:

• Constant Field Values

DRY_RUN_CONF_KEY

static final String DRY_RUN_CONF_KEY

See Also:

• Constant Field Values

DO_DELETES_CONF_KEY

static final String DO_DELETES_CONF_KEY

See Also:

• Constant Field Values

DO_PUTS_CONF_KEY

static final String DO_PUTS_CONF_KEY

See Also:

• Constant Field Values

IGNORE_TIMESTAMPS

static final String IGNORE_TIMESTAMPS

See Also:

• Constant Field Values

sourceHashDir

org.apache.hadoop.fs.Path sourceHashDir

sourceTableName

String sourceTableName

targetTableName

String targetTableName

sourceZkCluster

String sourceZkCluster

targetZkCluster

String targetZkCluster

dryRun

boolean dryRun

doDeletes

boolean doDeletes

doPuts

boolean doPuts

ignoreTimestamps

boolean ignoreTimestamps

counters

org.apache.hadoop.mapreduce.Counters counters

NUM_ARGS

private static final int NUM_ARGS

See Also:

• Constant Field Values

Constructor Details

SyncTable

public SyncTable(org.apache.hadoop.conf.Configuration conf)

Method Details

initCredentialsForHBase

private void initCredentialsForHBase(String zookeeper,
 org.apache.hadoop.mapreduce.Job job)
                              throws IOException

Throws:

IOException

createSubmittableJob

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

Throws:

IOException

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.

Throws:

Exception

run

public int run(String[] args)
        throws Exception

Specified by:

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

Throws:

Exception