org.apache.flume.instrumentation

Class SourceCounter

java.lang.Object

org.apache.flume.instrumentation.MonitoredCounterGroup

org.apache.flume.instrumentation.SourceCounter

All Implemented Interfaces:

SourceCounterMBean

Direct Known Subclasses:

KafkaSourceCounter

public class SourceCounter
extends MonitoredCounterGroup
implements SourceCounterMBean

Nested Class Summary

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

MonitoredCounterGroup.Type

Constructor Summary

Constructors

Constructor and Description
SourceCounter(String name)
SourceCounter(String name, String[] attributes)

Method Summary

Modifier and Type	Method and Description
long	addToEventAcceptedCount(long delta)
long	addToEventReceivedCount(long delta)
long	getAppendAcceptedCount()
long	getAppendBatchAcceptedCount()
long	getAppendBatchReceivedCount()
long	getAppendReceivedCount()
long	getChannelWriteFail()
long	getEventAcceptedCount()
long	getEventReadFail()
long	getEventReceivedCount()
long	getGenericProcessingFail()
long	getOpenConnectionCount()
long	incrementAppendAcceptedCount()
long	incrementAppendBatchAcceptedCount()
long	incrementAppendBatchReceivedCount()
long	incrementAppendReceivedCount()
long	incrementChannelWriteFail()
long	incrementEventAcceptedCount()
long	incrementEventReadFail()
long	incrementEventReadOrChannelFail(Throwable t)
long	incrementEventReceivedCount()
long	incrementGenericProcessingFail()
void	setOpenConnectionCount(long openConnectionCount)

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.SourceCounterMBean

getStartTime, getStopTime, getType

Constructor Detail

SourceCounter

public SourceCounter(String name)

SourceCounter

public SourceCounter(String name,
                     String[] attributes)

Method Detail

getEventReceivedCount

public long getEventReceivedCount()

Specified by:

getEventReceivedCount in interface SourceCounterMBean

incrementEventReceivedCount

public long incrementEventReceivedCount()

addToEventReceivedCount

public long addToEventReceivedCount(long delta)

getEventAcceptedCount

public long getEventAcceptedCount()

Specified by:

getEventAcceptedCount in interface SourceCounterMBean

incrementEventAcceptedCount

public long incrementEventAcceptedCount()

addToEventAcceptedCount

public long addToEventAcceptedCount(long delta)

getAppendReceivedCount

public long getAppendReceivedCount()

Specified by:

getAppendReceivedCount in interface SourceCounterMBean

incrementAppendReceivedCount

public long incrementAppendReceivedCount()

getAppendAcceptedCount

public long getAppendAcceptedCount()

Specified by:

getAppendAcceptedCount in interface SourceCounterMBean

incrementAppendAcceptedCount

public long incrementAppendAcceptedCount()

getAppendBatchReceivedCount

public long getAppendBatchReceivedCount()

Specified by:

getAppendBatchReceivedCount in interface SourceCounterMBean

incrementAppendBatchReceivedCount

public long incrementAppendBatchReceivedCount()

getAppendBatchAcceptedCount

public long getAppendBatchAcceptedCount()

Specified by:

getAppendBatchAcceptedCount in interface SourceCounterMBean

incrementAppendBatchAcceptedCount

public long incrementAppendBatchAcceptedCount()

getOpenConnectionCount

public long getOpenConnectionCount()

Specified by:

getOpenConnectionCount in interface SourceCounterMBean

setOpenConnectionCount

public void setOpenConnectionCount(long openConnectionCount)

incrementEventReadFail

public long incrementEventReadFail()

getEventReadFail

public long getEventReadFail()

Specified by:

getEventReadFail in interface SourceCounterMBean

incrementChannelWriteFail

public long incrementChannelWriteFail()

getChannelWriteFail

public long getChannelWriteFail()

Specified by:

getChannelWriteFail in interface SourceCounterMBean

incrementGenericProcessingFail

public long incrementGenericProcessingFail()

getGenericProcessingFail

public long getGenericProcessingFail()

Specified by:

getGenericProcessingFail in interface SourceCounterMBean

incrementEventReadOrChannelFail

public long incrementEventReadOrChannelFail(Throwable t)