Field Detail

• LOG

  private static final org.apache.commons.logging.Log 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

• sourceHashDir

  org.apache.hadoop.fs.Path sourceHashDir

• sourceTableName

  String sourceTableName

• targetTableName

  String targetTableName

• sourceZkCluster

  String sourceZkCluster

• targetZkCluster

  String targetZkCluster

• dryRun

  boolean dryRun

• 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

• 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