org.apache.accumulo.gc

Class GarbageCollectWriteAheadLogs

java.lang.Object

org.apache.accumulo.gc.GarbageCollectWriteAheadLogs

public class GarbageCollectWriteAheadLogs
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
void	collect(GCStatus status) Removes all the WAL files that are no longer used.
protected boolean	timeToDelete(com.google.common.net.HostAndPort address, long wait) Determine if TServer has been dead long enough to remove associated WALs.

Methods inherited from class java.lang.Object

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

Method Detail

collect

public void collect(GCStatus status)

Removes all the WAL files that are no longer used.

This method is not Threadsafe. SimpleGarbageCollector#run does not invoke collect in a concurrent manner.

Parameters:

status - GCStatus object

timeToDelete

protected boolean timeToDelete(com.google.common.net.HostAndPort address,
                   long wait)

Determine if TServer has been dead long enough to remove associated WALs.

Uses a map where the key is the address and the value is the time first seen dead. If the address is not in the map, it is added with the current system nanoTime. When the passed in wait time has elapsed, this method returns true and removes the key and value from the map.

Parameters:

address - HostAndPort of dead tserver

wait - long value of elapsed millis to wait

Returns:

boolean whether enough time elapsed since the server was first seen as dead.