Package org.apache.druid.query.groupby

Class GroupByStatsProvider

java.lang.Object

org.apache.druid.query.groupby.GroupByStatsProvider

public class GroupByStatsProvider
extends Object

Collects groupBy query metrics (spilled bytes, merge buffer usage, dictionary size) per-query, then aggregates them when queries complete. Stats are retrieved and reset periodically via getStatsSince().

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GroupByStatsProvider.AggregateStats
static class	GroupByStatsProvider.PerQueryStats

Constructor Summary

Constructors

Constructor	Description
GroupByStatsProvider()

Method Summary

Modifier and Type	Method	Description
void	closeQuery(QueryResourceId resourceId)
GroupByStatsProvider.PerQueryStats	getPerQueryStatsContainer(QueryResourceId resourceId)
GroupByStatsProvider.AggregateStats	getStatsSince()

Methods inherited from class java.lang.Object

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

Constructor Details

GroupByStatsProvider

public GroupByStatsProvider()

Method Details

getPerQueryStatsContainer

public GroupByStatsProvider.PerQueryStats getPerQueryStatsContainer(QueryResourceId resourceId)

closeQuery

public void closeQuery(QueryResourceId resourceId)

getStatsSince

public GroupByStatsProvider.AggregateStats getStatsSince()