Constructor Detail

• ZKSplitTransactionCoordination

  public ZKSplitTransactionCoordination(CoordinatedStateManager coordinationProvider,
                                ZooKeeperWatcher watcher)

Method Detail

• startSplitTransaction

  public void startSplitTransaction(HRegion parent,
                           ServerName serverName,
                           HRegionInfo hri_a,
                           HRegionInfo hri_b)
                             throws IOException

  Creates a new ephemeral node in the PENDING_SPLIT state for the specified region. Create it ephemeral in case regionserver dies mid-split.

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

  Specified by:

  startSplitTransaction in interface SplitTransactionCoordination

  Parameters:

  parent - region to be created as offline

  serverName - server event originates from

  hri_a - daughter region

  hri_b - daughter region

  Throws:

  IOException

• waitForSplitTransaction

  public void waitForSplitTransaction(RegionServerServices services,
                             Region parent,
                             HRegionInfo hri_a,
                             HRegionInfo hri_b,
                             SplitTransactionCoordination.SplitTransactionDetails sptd)
                               throws IOException

  Wait for the splitting node to be transitioned from pending_split to splitting 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_split state any more, we abort the split.

  Specified by:

  waitForSplitTransaction in interface SplitTransactionCoordination

  Parameters:

  services - Used to online/offline regions.

  parent - region

  hri_a - daughter region

  hri_b - daughter region

  sptd - split transaction details

  Throws:

  IOException

• completeSplitTransaction

  public void completeSplitTransaction(RegionServerServices services,
                              Region a,
                              Region b,
                              SplitTransactionCoordination.SplitTransactionDetails std,
                              Region parent)
                                throws IOException

  Finish off split transaction, transition the zknode

  Specified by:

  completeSplitTransaction in interface SplitTransactionCoordination

  Parameters:

  services - Used to online/offline regions.

  a - daughter region

  b - daughter region

  std - split transaction details

  parent -

  Throws:

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

• clean

  public void clean(HRegionInfo hri)

  Description copied from interface: SplitTransactionCoordination
  clean the split transaction

  Specified by:

  clean in interface SplitTransactionCoordination

  Parameters:

  hri - node to delete

• getDefaultDetails

  public SplitTransactionCoordination.SplitTransactionDetails getDefaultDetails()

  Specified by:

  getDefaultDetails in interface SplitTransactionCoordination

• processTransition

  public int processTransition(HRegionInfo p,
                      HRegionInfo hri_a,
                      HRegionInfo hri_b,
                      ServerName sn,
                      SplitTransactionCoordination.SplitTransactionDetails std)
                        throws IOException

  Description copied from interface: SplitTransactionCoordination
  Required by AssignmentManager

  Specified by:

  processTransition in interface SplitTransactionCoordination

  Throws:

  IOException