org.apache.flume.instrumentation
Class ChannelCounter
java.lang.Object
org.apache.flume.instrumentation.MonitoredCounterGroup
org.apache.flume.instrumentation.ChannelCounter
- All Implemented Interfaces:
- ChannelCounterMBean
public class ChannelCounter
- extends MonitoredCounterGroup
- implements ChannelCounterMBean
ChannelCounter
public ChannelCounter(String name)
getChannelSize
public long getChannelSize()
- Specified by:
getChannelSize
in interface ChannelCounterMBean
setChannelSize
public void setChannelSize(long newSize)
getEventPutAttemptCount
public long getEventPutAttemptCount()
- Specified by:
getEventPutAttemptCount
in interface ChannelCounterMBean
incrementEventPutAttemptCount
public long incrementEventPutAttemptCount()
getEventTakeAttemptCount
public long getEventTakeAttemptCount()
- Specified by:
getEventTakeAttemptCount
in interface ChannelCounterMBean
incrementEventTakeAttemptCount
public long incrementEventTakeAttemptCount()
getEventPutSuccessCount
public long getEventPutSuccessCount()
- Specified by:
getEventPutSuccessCount
in interface ChannelCounterMBean
addToEventPutSuccessCount
public long addToEventPutSuccessCount(long delta)
getEventTakeSuccessCount
public long getEventTakeSuccessCount()
- Specified by:
getEventTakeSuccessCount
in interface ChannelCounterMBean
addToEventTakeSuccessCount
public long addToEventTakeSuccessCount(long delta)
setChannelCapacity
public void setChannelCapacity(long capacity)
getChannelCapacity
public long getChannelCapacity()
- Specified by:
getChannelCapacity
in interface ChannelCounterMBean
getChannelFillPercentage
public double getChannelFillPercentage()
- Specified by:
getChannelFillPercentage
in interface ChannelCounterMBean
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.