Method Detail

• init

  void init(org.apache.hadoop.conf.Configuration conf,
          org.apache.hadoop.fs.FileSystem fs,
          ReplicationSourceManager manager,
          ReplicationQueues replicationQueues,
          ReplicationPeers replicationPeers,
          Stoppable stopper,
          String peerClusterZnode,
          UUID clusterId,
          ReplicationEndpoint replicationEndpoint,
          MetricsSource metrics)
            throws IOException

  Initializer for the source

  Parameters:

  conf - the configuration to use

  fs - the file system to use

  manager - the manager to use

  replicationQueues -

  replicationPeers -

  stopper - the stopper object for this region server

  peerClusterZnode -

  clusterId -

  Throws:

  IOException

• enqueueLog

  void enqueueLog(org.apache.hadoop.fs.Path log)

  Add a log to the list of logs to replicate

  Parameters:

  log - path to the log to replicate

• getCurrentPath

  org.apache.hadoop.fs.Path getCurrentPath()

  Get the current log that's replicated

  Returns:

  the current log

• startup

  void startup()

  Start the replication

• terminate

  void terminate(String reason)

  End the replication

  Parameters:

  reason - why it's terminating

• terminate

  void terminate(String reason,
               Exception cause)

  End the replication

  Parameters:

  reason - why it's terminating

  cause - the error that's causing it

• getPeerClusterZnode

  String getPeerClusterZnode()

  Get the id that the source is replicating to

  Returns:

  peer cluster id

• getPeerClusterId

  String getPeerClusterId()

  Get the id that the source is replicating to.

  Returns:

  peer cluster id

• getStats

  String getStats()

  Get a string representation of the current statistics for this source

  Returns:

  printable stats

• addHFileRefs

  void addHFileRefs(TableName tableName,
                  byte[] family,
                  List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
                    throws ReplicationException

  Add hfile names to the queue to be replicated.

  Parameters:

  tableName - Name of the table these files belongs to

  family - Name of the family these files belong to

  pairs - list of pairs of { HFile location in staging dir, HFile path in region dir which will be added in the queue for replication}

  Throws:

  ReplicationException - If failed to add hfile references

• getSourceMetrics

  MetricsSource getSourceMetrics()

  Get the associated metrics.

  Returns:

  The metrics for this source.