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

@InterfaceAudience.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 and Description
static class	SyncTable.SyncMapper

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.mapreduce.Counters	counters
(package private) static String	DO_DELETES_CONF_KEY
(package private) static String	DO_PUTS_CONF_KEY
(package private) boolean	doDeletes
(package private) boolean	doPuts
(package private) static String	DRY_RUN_CONF_KEY
(package private) boolean	dryRun
private static org.slf4j.Logger	LOG
private static int	NUM_ARGS
(package private) static String	SOURCE_HASH_DIR_CONF_KEY
(package private) static String	SOURCE_TABLE_CONF_KEY
(package private) static 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 String	TARGET_TABLE_CONF_KEY
(package private) static String	TARGET_ZK_CLUSTER_CONF_KEY
(package private) String	targetTableName
(package private) String	targetZkCluster

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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

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

counters

org.apache.hadoop.mapreduce.Counters counters

NUM_ARGS

private static final int NUM_ARGS

See Also:

Constant Field Values

Constructor Detail

SyncTable

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

Method Detail

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