Package org.apache.hadoop.hbase.coprocessor.example

Class ZooKeeperScanPolicyObserver.ZKDataHolder

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.ZooKeeperScanPolicyObserver.ZKDataHolder

Enclosing class:

ZooKeeperScanPolicyObserver

private static final class ZooKeeperScanPolicyObserver.ZKDataHolder
extends Object

Internal watcher that keep "data" up to date asynchronously.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.curator.framework.recipes.cache.NodeCache	cache
private org.apache.curator.framework.CuratorFramework	client
private final String	ensemble
private int	ref
private final int	sessionTimeout

Constructor Summary

Constructors

Constructor	Description
ZKDataHolder(String ensemble, int sessionTimeout)

Method Summary

Modifier and Type	Method	Description
org.apache.curator.framework.recipes.cache.NodeCache	acquire()
private void	close()
private void	create()
void	release()

Methods inherited from class java.lang.Object

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

Field Details

ensemble

private final String ensemble

sessionTimeout

private final int sessionTimeout

client

private org.apache.curator.framework.CuratorFramework client

cache

private org.apache.curator.framework.recipes.cache.NodeCache cache

ref

private int ref

Constructor Details

ZKDataHolder

public ZKDataHolder(String ensemble,
 int sessionTimeout)

Method Details

create

private void create()
             throws Exception

Throws:

Exception

close

private void close()

acquire

public org.apache.curator.framework.recipes.cache.NodeCache acquire()
                                                             throws Exception

Throws:

Exception

release

public void release()