Package org.apache.hadoop.hbase.coordination

Class ZKSplitLogManagerCoordination.CreateRescanAsyncCallback

java.lang.Object
org.apache.hadoop.hbase.coordination.ZKSplitLogManagerCoordination.CreateRescanAsyncCallback
All Implemented Interfaces:
org.apache.zookeeper.AsyncCallback, org.apache.zookeeper.AsyncCallback.StringCallback
Enclosing class:
ZKSplitLogManagerCoordination
public class ZKSplitLogManagerCoordination.CreateRescanAsyncCallback extends Object implements org.apache.zookeeper.AsyncCallback.StringCallback
Asynchronous handler for zk create RESCAN-node results. Retries on failures.

A RESCAN node is created using PERSISTENT_SEQUENTIAL flag. It is a signal for all the SplitLogWorkers to rescan for new tasks.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.zookeeper.AsyncCallback

    org.apache.zookeeper.AsyncCallback.ACLCallback, org.apache.zookeeper.AsyncCallback.AllChildrenNumberCallback, org.apache.zookeeper.AsyncCallback.Children2Callback, org.apache.zookeeper.AsyncCallback.ChildrenCallback, org.apache.zookeeper.AsyncCallback.Create2Callback, org.apache.zookeeper.AsyncCallback.DataCallback, org.apache.zookeeper.AsyncCallback.EphemeralsCallback, org.apache.zookeeper.AsyncCallback.MultiCallback, org.apache.zookeeper.AsyncCallback.StatCallback, org.apache.zookeeper.AsyncCallback.StringCallback, org.apache.zookeeper.AsyncCallback.VoidCallback

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final org.slf4j.Logger
    LOG
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CreateRescanAsyncCallback()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    processResult(int rc, String path, Object ctx, String name)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • LOG

      private final org.slf4j.Logger LOG

  • Constructor Details

  • Method Details

    • processResult

      public void processResult(int rc, String path, Object ctx, String name)
      Specified by:
      processResult in interface org.apache.zookeeper.AsyncCallback.StringCallback