Constructor Detail

• ZkRegionMergeCoordination

  public ZkRegionMergeCoordination(CoordinatedStateManager manager,
                           ZooKeeperWatcher watcher)

Method Detail

• getDefaultDetails

  public RegionMergeCoordination.RegionMergeDetails getDefaultDetails()

  Specified by:

  getDefaultDetails in interface RegionMergeCoordination

• waitForRegionMergeTransaction

  public void waitForRegionMergeTransaction(RegionServerServices services,
                                   HRegionInfo mergedRegionInfo,
                                   HRegion region_a,
                                   HRegion region_b,
                                   RegionMergeCoordination.RegionMergeDetails details)
                                     throws IOException

  Wait for the merging node to be transitioned from pending_merge to merging by master. That's how we are sure master has processed the event and is good with us to move on. If we don't get any update, we periodically transition the node so that master gets the callback. If the node is removed or is not in pending_merge state any more, we abort the merge.

  Specified by:

  waitForRegionMergeTransaction in interface RegionMergeCoordination

  Throws:

  IOException

• startRegionMergeTransaction

  public void startRegionMergeTransaction(HRegionInfo region,
                                 ServerName serverName,
                                 HRegionInfo a,
                                 HRegionInfo b)
                                   throws IOException

  Creates a new ephemeral node in the PENDING_MERGE state for the merged region. Create it ephemeral in case regionserver dies mid-merge.

  Does not transition nodes from other states. If a node already exists for this region, a KeeperException.NodeExistsException will be thrown.

  Specified by:

  startRegionMergeTransaction in interface RegionMergeCoordination

  Parameters:

  region - region to be created as offline

  serverName - server event originates from

  Throws:

  IOException

• clean

  public void clean(HRegionInfo hri)

  Description copied from interface: RegionMergeCoordination
  This method is used during rollback

  Specified by:

  clean in interface RegionMergeCoordination

  Parameters:

  hri - region to be rolled back

• completeRegionMergeTransaction

  public void completeRegionMergeTransaction(RegionServerServices services,
                                    HRegionInfo mergedRegionInfo,
                                    HRegion region_a,
                                    HRegion region_b,
                                    RegionMergeCoordination.RegionMergeDetails rmd,
                                    HRegion mergedRegion)
                                      throws IOException

  Description copied from interface: RegionMergeCoordination
  Finish off merge transaction

  Specified by:

  completeRegionMergeTransaction in interface RegionMergeCoordination

  Parameters:

  services - Used to online/offline regions.

  mergedRegionInfo - region

  region_a - merging region A

  region_b - merging region B

  rmd - region merge details

  Throws:

  IOException - If thrown, transaction failed. Call RegionMergeTransaction.rollback( Server, RegionServerServices)

• confirmRegionMergeTransaction

  public void confirmRegionMergeTransaction(HRegionInfo merged,
                                   HRegionInfo a,
                                   HRegionInfo b,
                                   ServerName serverName,
                                   RegionMergeCoordination.RegionMergeDetails rmd)
                                     throws IOException

  Description copied from interface: RegionMergeCoordination
  Confirm that the region merge can be performed

  Specified by:

  confirmRegionMergeTransaction in interface RegionMergeCoordination

  Parameters:

  merged - region

  a - merging region A

  b - merging region B

  serverName - server event originates from

  rmd - region merge details

  Throws:

  IOException - If thrown, transaction failed.

• processRegionMergeRequest

  public void processRegionMergeRequest(HRegionInfo p,
                               HRegionInfo hri_a,
                               HRegionInfo hri_b,
                               ServerName sn,
                               RegionMergeCoordination.RegionMergeDetails rmd)
                                 throws IOException

  Specified by:

  processRegionMergeRequest in interface RegionMergeCoordination

  Parameters:

  p - region

  hri_a - merging region A

  hri_b - merging region B

  sn - server event originates from

  rmd - region merge details

  Throws:

  IOException