@InterfaceAudience.Private public class SyncTable extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool
Modifier and Type | Class and Description |
---|---|
static class |
SyncTable.SyncMapper |
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 |
(package private) static String |
IGNORE_TIMESTAMPS |
(package private) boolean |
ignoreTimestamps |
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 and Description |
---|
SyncTable(org.apache.hadoop.conf.Configuration conf) |
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) |
private static final org.slf4j.Logger LOG
static final String SOURCE_HASH_DIR_CONF_KEY
static final String SOURCE_TABLE_CONF_KEY
static final String TARGET_TABLE_CONF_KEY
static final String SOURCE_ZK_CLUSTER_CONF_KEY
static final String TARGET_ZK_CLUSTER_CONF_KEY
static final String DRY_RUN_CONF_KEY
static final String DO_DELETES_CONF_KEY
static final String DO_PUTS_CONF_KEY
static final String IGNORE_TIMESTAMPS
org.apache.hadoop.fs.Path sourceHashDir
String sourceTableName
String targetTableName
String sourceZkCluster
String targetZkCluster
boolean dryRun
boolean doDeletes
boolean doPuts
boolean ignoreTimestamps
org.apache.hadoop.mapreduce.Counters counters
private static final int NUM_ARGS
public SyncTable(org.apache.hadoop.conf.Configuration conf)
private void initCredentialsForHBase(String zookeeper, org.apache.hadoop.mapreduce.Job job) throws IOException
IOException
public org.apache.hadoop.mapreduce.Job createSubmittableJob(String[] args) throws IOException
IOException
private static void printUsage(String errorMsg)
private boolean doCommandLine(String[] args)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.