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 and Description
private org.apache.curator.framework.recipes.cache.NodeCache	cache
private org.apache.curator.framework.CuratorFramework	client
private String	ensemble
private int	ref
private int	sessionTimeout

Constructor Summary

Constructors

Constructor and Description
ZKDataHolder(String ensemble, int sessionTimeout)

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

ZKDataHolder

public ZKDataHolder(String ensemble,
                    int sessionTimeout)

Method Detail

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()