org.apache.samza.util

Class BlockingEnvelopeMap.BlockingEnvelopeMapMetrics

java.lang.Object

org.apache.samza.util.BlockingEnvelopeMap.BlockingEnvelopeMapMetrics

Enclosing class:

BlockingEnvelopeMap

public class BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
BlockingEnvelopeMapMetrics(java.lang.String group, MetricsRegistry metricsRegistry)

Method Summary

Modifier and Type	Method and Description
void	incBlockingPoll(SystemStreamPartition systemStreamPartition)
void	incBlockingTimeoutPoll(SystemStreamPartition systemStreamPartition)
void	incPoll()
void	initMetrics(SystemStreamPartition systemStreamPartition)
void	setNoMoreMessages(SystemStreamPartition systemStreamPartition, boolean noMoreMessages)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingEnvelopeMapMetrics

public BlockingEnvelopeMapMetrics(java.lang.String group,
                                  MetricsRegistry metricsRegistry)

Method Detail

initMetrics

public void initMetrics(SystemStreamPartition systemStreamPartition)

setNoMoreMessages

public void setNoMoreMessages(SystemStreamPartition systemStreamPartition,
                              boolean noMoreMessages)

incBlockingPoll

public void incBlockingPoll(SystemStreamPartition systemStreamPartition)

incBlockingTimeoutPoll

public void incBlockingTimeoutPoll(SystemStreamPartition systemStreamPartition)

incPoll

public void incPoll()