Class ScalableTopicStats

java.lang.Object

org.apache.pulsar.common.policies.data.ScalableTopicStats

public class ScalableTopicStats
extends Object

Stats for a scalable topic as a whole: the segment layout (the DAG), the traffic and storage aggregated across every segment, the producers attached to the topic, and the subscriptions with their backlog broken down across segments.

Rates are rounded to three decimals. Per-segment numbers come from each segment's owning broker; a segment whose stats could not be collected keeps its layout entry but reports no owner (see

invalid reference

LayoutSegment#getOwnerBroker()

) and contributes nothing to the aggregates.

The stats of a single segment — its own rates and storage, its cursors and consumers — are served separately as SegmentTopicStats by ScalableTopics.getSegmentStats.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ScalableTopicStats.ConsumerStats	A consumer on a subscription.
static class	ScalableTopicStats.LayoutSegment	One node of the segment DAG: the segment's name (which encodes its hash range and ID), its state, its edges and the broker serving it.
static class	ScalableTopicStats.LayoutStats	The segment DAG: the layout epoch and every segment, active or sealed.
static class	ScalableTopicStats.ProducerStats	A producer attached to the topic.
static class	ScalableTopicStats.SegmentSubscriptionStats	The share of a subscription that lives on one segment.
static class	ScalableTopicStats.SubscriptionStats	A subscription on the scalable topic, aggregated across every segment that holds a cursor for it.

Constructor Summary

Constructors

Constructor	Description
ScalableTopicStats()

Method Summary

Methods inherited from class Object

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

Constructor Details

ScalableTopicStats

public ScalableTopicStats()