ZooKeeperScanPolicyObserver.ZKWatcher (Apache HBase 1.2.12 API)

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.coprocessor.example.ZooKeeperScanPolicyObserver.ZKWatcher

All Implemented Interfaces:

org.apache.zookeeper.Watcher

Enclosing class:

ZooKeeperScanPolicyObserver
```
private static class ZooKeeperScanPolicyObserver.ZKWatcher
extends Object
implements org.apache.zookeeper.Watcher
```
Internal watcher that keep "data" up to date asynchronously.

- Nested Class Summary
  - Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher
    org.apache.zookeeper.Watcher.Event
- Field Summary
  
  Fields
  Modifier and Type Field and Description
  
  private byte[] data
  
  private long lastSetupTry
  
  private boolean needSetup
  
  private org.apache.zookeeper.ZooKeeper zk
- Constructor Summary
  
  Constructors
  Constructor and Description
  
  ZooKeeperScanPolicyObserver.ZKWatcher(org.apache.zookeeper.ZooKeeper zk)
- Method Summary
  
  Methods
  Modifier and Type Method and Description
  
  byte[] getData()
  Get the maintained data.
  
  void process(org.apache.zookeeper.WatchedEvent event)
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - data
```
private byte[] data
```
  - zk
```
private org.apache.zookeeper.ZooKeeper zk
```
  - needSetup
```
private volatile boolean needSetup
```
  - lastSetupTry
```
private volatile long lastSetupTry
```
- Constructor Detail
  - ZooKeeperScanPolicyObserver.ZKWatcher
```
public ZooKeeperScanPolicyObserver.ZKWatcher(org.apache.zookeeper.ZooKeeper zk)
```
- Method Detail
  - getData
```
public byte[] getData()
```
    Get the maintained data. In case of any ZK exceptions this will retry establishing the connection (but not more than twice/minute). getData is on the critical path, so make sure it is fast unless there is a problem (network partion, ZK ensemble down, etc) Make sure at most one (unlucky) thread retries and other threads don't pile up while that threads tries to recreate the connection.
    
    Returns:
    the last know version of the data
  - process
```
public void process(org.apache.zookeeper.WatchedEvent event)
```
    Specified by:
    
    process in interface org.apache.zookeeper.Watcher

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.