Package org.apache.pulsar.common.policies.data

Class ScalableTopicStats

java.lang.Object

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

public class ScalableTopicStats
extends Object

Aggregated stats for a scalable topic.

Combines segment-DAG state (from the topic metadata) with per-subscription consumer counts (from the persisted consumer registrations). Per-segment throughput rates are not yet populated — that requires collecting stats from each segment-owning broker and will be added in a follow-up.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ScalableTopicStats.SegmentStats	Per-segment stats.
static final record	ScalableTopicStats.SubscriptionStats	Per-subscription stats.

Constructor Summary

Constructors

Constructor	Description
ScalableTopicStats()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

ScalableTopicStats

public ScalableTopicStats()