Package org.apache.cassandra.service.snapshot

Class SnapshotManager

java.lang.Object

org.apache.cassandra.service.snapshot.SnapshotManager

public class SnapshotManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected ScheduledFuture<?>	cleanupTaskFuture

Constructor Summary

Constructors

Modifier	Constructor	Description
	SnapshotManager()
protected	SnapshotManager(long initialDelaySeconds, long cleanupPeriodSeconds)

Method Summary

Modifier and Type	Method	Description
void	addSnapshot(TableSnapshot snapshot)
protected void	addSnapshots(Collection<TableSnapshot> snapshots)
protected void	clearExpiredSnapshots()
void	clearSnapshot(TableSnapshot snapshot)	Deletes snapshot and remove it from manager
Collection<TableSnapshot>	getExpiringSnapshots()
Set<TableSnapshot>	loadSnapshots()
Set<TableSnapshot>	loadSnapshots(String keyspace)
static void	shutdownAndWait(long timeout, TimeUnit unit)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

cleanupTaskFuture

protected volatile ScheduledFuture<?> cleanupTaskFuture

Constructor Details

SnapshotManager

public SnapshotManager()

SnapshotManager

protected SnapshotManager(long initialDelaySeconds,
 long cleanupPeriodSeconds)

Method Details

getExpiringSnapshots

public Collection<TableSnapshot> getExpiringSnapshots()

start

public void start()

stop

public void stop()
          throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

addSnapshot

public void addSnapshot(TableSnapshot snapshot)

loadSnapshots

public Set<TableSnapshot> loadSnapshots(String keyspace)

loadSnapshots

public Set<TableSnapshot> loadSnapshots()

addSnapshots

protected void addSnapshots(Collection<TableSnapshot> snapshots)

clearExpiredSnapshots

protected void clearExpiredSnapshots()

clearSnapshot

public void clearSnapshot(TableSnapshot snapshot)

Deletes snapshot and remove it from manager

shutdownAndWait

public static void shutdownAndWait(long timeout,
 TimeUnit unit)
                            throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException