org.apache.hadoop.hbase.replication

Class ReplicationTableBase.CreateReplicationTableWorker

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationTableBase.CreateReplicationTableWorker

All Implemented Interfaces:

Runnable

Enclosing class:

ReplicationTableBase

private class ReplicationTableBase.CreateReplicationTableWorker
extends Object
implements Runnable

Attempts to build the Replication Table. Will continue blocking until we have a valid Table for the Replication Table.

Field Summary

Fields

Modifier and Type	Field and Description
private Admin	admin

Constructor Summary

Constructors

Modifier	Constructor and Description
private	CreateReplicationTableWorker()

Method Summary

Modifier and Type	Method and Description
private void	createReplicationTable() Create the replication table with the provided HColumnDescriptor REPLICATION_COL_DESCRIPTOR in TableBasedReplicationQueuesImpl
private boolean	replicationTableExists() Checks whether the Replication Table exists yet
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

admin

private Admin admin

Constructor Detail

CreateReplicationTableWorker

private CreateReplicationTableWorker()

Method Detail

run

public void run()

Specified by:

run in interface Runnable

createReplicationTable

private void createReplicationTable()
                             throws IOException

Create the replication table with the provided HColumnDescriptor REPLICATION_COL_DESCRIPTOR in TableBasedReplicationQueuesImpl

Throws:

IOException

replicationTableExists

private boolean replicationTableExists()

Checks whether the Replication Table exists yet

Returns:

whether the Replication Table exists

Throws:

IOException