org.apache.flume.channel.file
Class Log

java.lang.Object
  org.apache.flume.channel.file.Log

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class Log
extends Object

Stores FlumeEvents on disk and pointers to the events in a in memory queue. Once a log object is created the replay method should be called to reconcile the on disk write ahead log with the last checkpoint of the queue. Before calling any of commitPut/commitTake/get/put/rollback/take Log.tryLockShared should be called and the above operations should only be called if tryLockShared returns true. After the operation and any additional modifications of the FlumeEventQueue, the Log.unlockShared method should be called.

Field Summary

static Set<String>	EXCLUDES Set of files that should be excluded from backup and restores.
static String	FILE_LOCK
static String	PREFIX

Method Summary

int	getCommittedCount()
int	getPutCount()
int	getReadCount()
int	getRollbackCount()
int	getTakeCount()

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

FILE_LOCK

public static final String FILE_LOCK

See Also:

Constant Field Values

EXCLUDES

public static final Set<String> EXCLUDES

Set of files that should be excluded from backup and restores.

Method Detail

getReadCount

public int getReadCount()

getPutCount

public int getPutCount()

getTakeCount

public int getTakeCount()

getCommittedCount

public int getCommittedCount()

getRollbackCount

public int getRollbackCount()