org.apache.samza.util

Class BlockingEnvelopeMap.BufferSizeGauge

java.lang.Object

org.apache.samza.metrics.Gauge<java.lang.Long>

org.apache.samza.util.BlockingEnvelopeMap.BufferSizeGauge

All Implemented Interfaces:

Metric

Enclosing class:

BlockingEnvelopeMap

public class BlockingEnvelopeMap.BufferSizeGauge
extends Gauge<java.lang.Long>

Constructor Summary

Constructors

Constructor and Description
BufferSizeGauge(SystemStreamPartition systemStreamPartition, java.lang.String name)

Method Summary

Modifier and Type	Method and Description
java.lang.Long	getValue()

Methods inherited from class org.apache.samza.metrics.Gauge

compareAndSet, getName, set, toString, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferSizeGauge

public BufferSizeGauge(SystemStreamPartition systemStreamPartition,
                       java.lang.String name)

Method Detail

getValue

public java.lang.Long getValue()

Overrides:

getValue in class Gauge<java.lang.Long>