org.apache.flume.channel.file.instrumentation

Class FileChannelCounter

java.lang.Object

org.apache.flume.instrumentation.MonitoredCounterGroup

org.apache.flume.instrumentation.ChannelCounter

org.apache.flume.channel.file.instrumentation.FileChannelCounter

All Implemented Interfaces:

FileChannelCounterMBean, ChannelCounterMBean

public class FileChannelCounter
extends ChannelCounter
implements FileChannelCounterMBean

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flume.instrumentation.MonitoredCounterGroup

MonitoredCounterGroup.Type

Constructor Summary

Constructors

Constructor and Description
FileChannelCounter(String name)

Method Summary

Modifier and Type	Method and Description
long	getCheckpointBackupWriteErrorCount() A count of the number of errors encountered while trying to write the backup checkpoints.
long	getCheckpointWriteErrorCount() A count of the number of errors encountered while trying to write the checkpoints.
int	getClosed() The numeric representation (0/1) of the negated value of the open flag.
long	getEventPutErrorCount() A count of the number of IOExceptions encountered while trying to put() onto the channel.
long	getEventTakeErrorCount() A count of the number of errors encountered while trying to take() from the channel, including IOExceptions and corruption-related errors.
int	getUnhealthy() A value of 0 represents that the channel is in a healthy state: it is either starting up (i.e.
void	incrementCheckpointBackupWriteErrorCount()
void	incrementCheckpointWriteErrorCount()
void	incrementEventPutErrorCount()
void	incrementEventTakeErrorCount()
boolean	isOpen()
void	setOpen(boolean open)
void	setUnhealthy(int unhealthy)

Methods inherited from class org.apache.flume.instrumentation.ChannelCounter

addToEventPutSuccessCount, addToEventTakeSuccessCount, getChannelCapacity, getChannelFillPercentage, getChannelSize, getEventPutAttemptCount, getEventPutSuccessCount, getEventTakeAttemptCount, getEventTakeSuccessCount, incrementEventPutAttemptCount, incrementEventTakeAttemptCount, setChannelCapacity, setChannelSize

Methods inherited from class org.apache.flume.instrumentation.MonitoredCounterGroup

addAndGet, get, getStartTime, getStopTime, getType, increment, set, start, stop, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flume.instrumentation.ChannelCounterMBean

getChannelCapacity, getChannelFillPercentage, getChannelSize, getEventPutAttemptCount, getEventPutSuccessCount, getEventTakeAttemptCount, getEventTakeSuccessCount, getStartTime, getStopTime, getType

Constructor Detail

FileChannelCounter

public FileChannelCounter(String name)

Method Detail

isOpen

public boolean isOpen()

Specified by:

isOpen in interface FileChannelCounterMBean

setOpen

public void setOpen(boolean open)

getClosed

public int getClosed()

Description copied from interface: FileChannelCounterMBean

The numeric representation (0/1) of the negated value of the open flag.

Specified by:

getClosed in interface FileChannelCounterMBean

getUnhealthy

public int getUnhealthy()

Description copied from interface: FileChannelCounterMBean

A value of 0 represents that the channel is in a healthy state: it is either starting up (i.e. the replay is running) or already started up successfully. A value of 1 represents that the channel is in a permanently failed state, which means that the startup was unsuccessful due to an exception during the replay. Once the channel started up successfully the *ErrorCount (or the ratio of the *AttemptCount and *SuccessCount) counters should be used to check whether it is functioning properly. Note: this flag doesn't report the channel as unhealthy if the configuration failed because the ChannelCounter might not have been instantiated/started yet.

Specified by:

getUnhealthy in interface FileChannelCounterMBean

setUnhealthy

public void setUnhealthy(int unhealthy)

getEventPutErrorCount

public long getEventPutErrorCount()

Description copied from interface: FileChannelCounterMBean

A count of the number of IOExceptions encountered while trying to put() onto the channel.

Specified by:

getEventPutErrorCount in interface FileChannelCounterMBean

See Also:

#doPut(org.apache.flume.Event)

incrementEventPutErrorCount

public void incrementEventPutErrorCount()

getEventTakeErrorCount

public long getEventTakeErrorCount()

Description copied from interface: FileChannelCounterMBean

A count of the number of errors encountered while trying to take() from the channel, including IOExceptions and corruption-related errors.

Specified by:

getEventTakeErrorCount in interface FileChannelCounterMBean

See Also:

FileChannel.FileBackedTransaction.doTake()

incrementEventTakeErrorCount

public void incrementEventTakeErrorCount()

getCheckpointWriteErrorCount

public long getCheckpointWriteErrorCount()

Description copied from interface: FileChannelCounterMBean

A count of the number of errors encountered while trying to write the checkpoints. This includes any Throwables.

Specified by:

getCheckpointWriteErrorCount in interface FileChannelCounterMBean

See Also:

Log.BackgroundWorker.run()

incrementCheckpointWriteErrorCount

public void incrementCheckpointWriteErrorCount()

getCheckpointBackupWriteErrorCount

public long getCheckpointBackupWriteErrorCount()

Description copied from interface: FileChannelCounterMBean

A count of the number of errors encountered while trying to write the backup checkpoints. This includes any Throwables.

Specified by:

getCheckpointBackupWriteErrorCount in interface FileChannelCounterMBean

See Also:

EventQueueBackingStoreFile.startBackupThread()

incrementCheckpointBackupWriteErrorCount

public void incrementCheckpointBackupWriteErrorCount()