HelixPropertyStore

implements BaseDataAccessor<T>

org.apache.helix.store.HelixPropertyStore<T>

Known Indirect Subclasses

ZkCacheBaseDataAccessor<T>, ZkHelixPropertyStore<T>

Summary

Public Methods
abstract void	start() Perform resource allocation when property store starts Resource allocation includes: - start an internal thread for fire callbacks
abstract void	stop() Perform clean up when property store stops Cleanup includes: - stop the internal thread for fire callbacks
abstract void	subscribe(String parentPath, HelixPropertyListener listener) Register a listener to a parent path.
abstract void	unsubscribe(String parentPath, HelixPropertyListener listener) Remove a listener from a parent path.

[Expand]

Inherited Methods

From interface org.apache.helix.BaseDataAccessor

abstract boolean	create(String path, T record, int options) This will always attempt to create the znode, if it exists it will return false.
abstract boolean[]	createChildren(List<String> paths, List<T> records, int options) Use it when creating children under a parent node.
abstract boolean[]	exists(List<String> paths, int options) checks if the all the paths exists
abstract boolean	exists(String path, int options) checks if the path exists in zk
abstract List<T>	get(List<String> paths, List<Stat> stats, int options) Get List of T corresponding to the paths using async api
abstract T	get(String path, Stat stat, int options) Get the T corresponding to the path
abstract List<String>	getChildNames(String parentPath, int options) Returns the child names given a parent path
abstract List<T>	getChildren(String parentPath, List<Stat> stats, int options) Get the children under a parent path using async api
abstract Stat	getStat(String path, int options) Get the stats of a single path
abstract Stat[]	getStats(List<String> paths, int options) Get the stats of all the paths
abstract boolean[]	remove(List<String> paths, int options) remove multiple paths using async api.
abstract boolean	remove(String path, int options) This will remove the ZNode and all its descendants if any
abstract void	reset() TODO refactor this.
abstract boolean	set(String path, T record, int options) This will always attempt to set the data on existing node.
abstract boolean	set(String path, T record, int expectVersion, int options) This will attempt to set the data on existing node only if version matches.
abstract boolean[]	setChildren(List<String> paths, List<T> records, int options) can set multiple children under a parent node.
abstract List<String>	subscribeChildChanges(String path, IZkChildListener listener) Subscribe child listener to path
abstract void	subscribeDataChanges(String path, IZkDataListener listener) Subscribe data listener to path
abstract void	unsubscribeChildChanges(String path, IZkChildListener listener) Unsubscribe child listener to path
abstract void	unsubscribeDataChanges(String path, IZkDataListener listener) Unsubscribe data listener to path
abstract boolean	update(String path, DataUpdater<T> updater, int options) This will attempt to update the data using the updater.
abstract boolean[]	updateChildren(List<String> paths, List<DataUpdater<T>> updaters, int options) Can update multiple nodes using async api for better performance.

Public Methods

public abstract void start ()

Perform resource allocation when property store starts Resource allocation includes: - start an internal thread for fire callbacks

public abstract void stop ()

Perform clean up when property store stops Cleanup includes: - stop the internal thread for fire callbacks

public abstract void subscribe (String parentPath, HelixPropertyListener listener)

Register a listener to a parent path. Subscribing to a parent path means any changes happening under the parent path will notify the listener

public abstract void unsubscribe (String parentPath, HelixPropertyListener listener)

Remove a listener from a parent path. This will remove the listener from receiving any notifications happening under the parent path

Interfaces

Classes