org.apache.hadoop.hbase.zookeeper

Class SnapshotCleanupTracker

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKListener

org.apache.hadoop.hbase.zookeeper.ZKNodeTracker

org.apache.hadoop.hbase.zookeeper.SnapshotCleanupTracker

@InterfaceAudience.Private
public class SnapshotCleanupTracker
extends ZKNodeTracker

Tracks status of snapshot auto cleanup based on TTL

Field Summary

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKNodeTracker

abortable, LOG, node

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

watcher

Constructor Summary

Constructors

Constructor and Description
SnapshotCleanupTracker(ZKWatcher watcher, Abortable abortable) Constructs a new ZK node tracker.

Method Summary

Modifier and Type	Method and Description
boolean	isSnapshotCleanupEnabled() Returns the current state of the snapshot auto cleanup based on TTL
private org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotCleanupProtos.SnapshotCleanupState	parseFrom(byte[] pbBytes)
void	setSnapshotCleanupEnabled(boolean snapshotCleanupEnabled) Set snapshot auto clean on/off
private byte[]	toByteArray(boolean isSnapshotCleanupEnabled)

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKNodeTracker

blockUntilAvailable, blockUntilAvailable, checkIfBaseNodeAvailable, getData, getNode, nodeCreated, nodeDataChanged, nodeDeleted, start, stop, toString

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

getWatcher, nodeChildrenChanged

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotCleanupTracker

public SnapshotCleanupTracker(ZKWatcher watcher,
                              Abortable abortable)

Constructs a new ZK node tracker.

After construction, use ZKNodeTracker.start() to kick off tracking.

Parameters:

watcher - reference to the ZKWatcher which also contains configuration and constants

abortable - used to abort if a fatal error occurs

Method Detail

isSnapshotCleanupEnabled

public boolean isSnapshotCleanupEnabled()

Returns the current state of the snapshot auto cleanup based on TTL

Returns:

true if the snapshot auto cleanup is enabled, false otherwise.

setSnapshotCleanupEnabled

public void setSnapshotCleanupEnabled(boolean snapshotCleanupEnabled)
                               throws org.apache.zookeeper.KeeperException

Set snapshot auto clean on/off

Parameters:

snapshotCleanupEnabled - true if the snapshot auto cleanup should be on, false otherwise

Throws:

org.apache.zookeeper.KeeperException - if ZooKeeper operation fails

toByteArray

private byte[] toByteArray(boolean isSnapshotCleanupEnabled)

parseFrom

private org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotCleanupProtos.SnapshotCleanupState parseFrom(byte[] pbBytes)
                                                                                                        throws DeserializationException

Throws:

DeserializationException