org.apache.hadoop.hbase.mapreduce

Class BigtableSyncTableAccessor

java.lang.Object

org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

@InternalApi
public class BigtableSyncTableAccessor
extends Object

A helper class to provide access to package protected variables of SyncTable.

Method Summary

Modifier and Type	Method and Description
static String	getConfDryRunKey()
static Connection	getSourceConnection(SyncTable.SyncMapper mapper)
static org.apache.hadoop.fs.Path	getSourceHashDir(SyncTable syncTable)
static Table	getSourceTable(SyncTable.SyncMapper mapper)
static String	getSourceTableConfKey()
static String	getSourceTableName(SyncTable syncTable)
static String	getSourceZkCluster(SyncTable syncTable)
static String	getSourceZkClusterConfKey()
static Connection	getTargetConnection(SyncTable.SyncMapper mapper)
static Table	getTargetTable(SyncTable.SyncMapper mapper)
static String	getTargetTableConfKey()
static String	getTargetTableName(SyncTable syncTable)
static String	getTargetZkCluster(SyncTable syncTable)
static String	getTargetZkClusterConfKey()
static void	setDoDeletes(SyncTable syncTable, boolean doDeletes)
static void	setDoPuts(SyncTable syncTable, boolean doPuts)
static void	setDryRun(SyncTable syncTable, boolean dryRun)
static void	setIgnoreTimestamps(SyncTable syncTable, boolean ignoreTimestamps)
static Connection	setSourceConnection(SyncTable.SyncMapper mapper, Connection sourceConn)
static void	setSourceHashDir(SyncTable syncTable, org.apache.hadoop.fs.Path sourceHashDir)
static void	setSourceTable(SyncTable.SyncMapper mapper, Table sourceTable)
static void	setSourceTableName(SyncTable syncTable, String sourceTableName)
static void	setSourceZkCluster(SyncTable syncTable, String sourceZkCluster)
static Connection	setTargetConnection(SyncTable.SyncMapper mapper, Connection targetConn)
static void	setTargetTable(SyncTable.SyncMapper mapper, Table targetTable)
static void	setTargetTableName(SyncTable syncTable, String targetTableName)
static void	setTargetZkCluster(SyncTable syncTable, String targetZkCluster)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getSourceZkCluster

public static String getSourceZkCluster(SyncTable syncTable)

setSourceZkCluster

public static void setSourceZkCluster(SyncTable syncTable,
                                      String sourceZkCluster)

getSourceHashDir

public static org.apache.hadoop.fs.Path getSourceHashDir(SyncTable syncTable)

setSourceHashDir

public static void setSourceHashDir(SyncTable syncTable,
                                    org.apache.hadoop.fs.Path sourceHashDir)

getSourceTableName

public static String getSourceTableName(SyncTable syncTable)

setSourceTableName

public static void setSourceTableName(SyncTable syncTable,
                                      String sourceTableName)

getTargetZkCluster

public static String getTargetZkCluster(SyncTable syncTable)

setTargetZkCluster

public static void setTargetZkCluster(SyncTable syncTable,
                                      String targetZkCluster)

getTargetTableName

public static String getTargetTableName(SyncTable syncTable)

setTargetTableName

public static void setTargetTableName(SyncTable syncTable,
                                      String targetTableName)

getConfDryRunKey

public static String getConfDryRunKey()

setDryRun

public static void setDryRun(SyncTable syncTable,
                             boolean dryRun)

setDoDeletes

public static void setDoDeletes(SyncTable syncTable,
                                boolean doDeletes)

setDoPuts

public static void setDoPuts(SyncTable syncTable,
                             boolean doPuts)

setIgnoreTimestamps

public static void setIgnoreTimestamps(SyncTable syncTable,
                                       boolean ignoreTimestamps)

getSourceConnection

public static Connection getSourceConnection(SyncTable.SyncMapper mapper)

getSourceTable

public static Table getSourceTable(SyncTable.SyncMapper mapper)

getTargetConnection

public static Connection getTargetConnection(SyncTable.SyncMapper mapper)
                                      throws IOException

Throws:

IOException

getTargetTable

public static Table getTargetTable(SyncTable.SyncMapper mapper)

getTargetZkClusterConfKey

public static String getTargetZkClusterConfKey()

getSourceZkClusterConfKey

public static String getSourceZkClusterConfKey()

getSourceTableConfKey

public static String getSourceTableConfKey()

getTargetTableConfKey

public static String getTargetTableConfKey()

setSourceConnection

public static Connection setSourceConnection(SyncTable.SyncMapper mapper,
                                             Connection sourceConn)

setSourceTable

public static void setSourceTable(SyncTable.SyncMapper mapper,
                                  Table sourceTable)

setTargetConnection

public static Connection setTargetConnection(SyncTable.SyncMapper mapper,
                                             Connection targetConn)

setTargetTable

public static void setTargetTable(SyncTable.SyncMapper mapper,
                                  Table targetTable)