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
SourceCounter
public SourceCounter(String name)
SourceCounter
public SourceCounter(String name,
String[] attributes)
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)
Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.