public class

StatsAggregationStage

extends AbstractBaseStage
java.lang.Object
   ↳ org.apache.helix.controller.pipeline.AbstractBaseStage
     ↳ org.apache.helix.controller.stages.StatsAggregationStage

Class Overview

For each LiveInstances select currentState and message whose sessionId matches sessionId from LiveInstance Get Partition,State for all the resources computed in previous State [ResourceComputationStage]

Summary

Constants
int ALERT_HISTORY_SIZE
Fields
public final String ESPRESSO_STAT_REPORT_NAME
public final String PARTICIPANT_STAT_REPORT_NAME
public final String REPORT_NAME
public StatHealthReportProvider _aggStatsProvider
Public Constructors
StatsAggregationStage()
Public Methods
String getAgeStatName(String instance)
Map<String, Map<String, AlertValueAndStatus>> getAlertStatus()
ClusterAlertMBeanCollection getClusterAlertMBeanCollection()
Map<String, Tuple<String>> getStatStatus()
void init(StageContext context)
Initialize a stage
static String parseInstanceName(String actualStatName, HelixManager manager)
static String parsePartitionName(String actualStatName, HelixManager manager)
static String parseResourceName(String actualStatName, HelixManager manager)
void persistAggStats(HelixManager manager)
void process(ClusterEvent event)
Actual callback processing logic
void reportAgeStat(LiveInstance instance, long modifiedTime, long currTime)
[Expand]
Inherited Methods
From class org.apache.helix.controller.pipeline.AbstractBaseStage
From class java.lang.Object
From interface org.apache.helix.controller.pipeline.Stage

Constants

public static final int ALERT_HISTORY_SIZE

Constant Value: 30 (0x0000001e)

Fields

public final String ESPRESSO_STAT_REPORT_NAME

Constant Value: "RestQueryStats"

public final String PARTICIPANT_STAT_REPORT_NAME

Constant Value: "ParticipantStats"

public final String REPORT_NAME

Constant Value: "AggStats"

public StatHealthReportProvider _aggStatsProvider

Public Constructors

public StatsAggregationStage ()

Public Methods

public String getAgeStatName (String instance)

public Map<String, Map<String, AlertValueAndStatus>> getAlertStatus ()

public ClusterAlertMBeanCollection getClusterAlertMBeanCollection ()

public Map<String, Tuple<String>> getStatStatus ()

public void init (StageContext context)

Initialize a stage

public static String parseInstanceName (String actualStatName, HelixManager manager)

public static String parsePartitionName (String actualStatName, HelixManager manager)

public static String parseResourceName (String actualStatName, HelixManager manager)

public void persistAggStats (HelixManager manager)

public void process (ClusterEvent event)

Actual callback processing logic

Throws
Exception

public void reportAgeStat (LiveInstance instance, long modifiedTime, long currTime)