org.openspaces.admin.internal.pu

Class DefaultProcessingUnitStatistics

java.lang.Object

org.openspaces.admin.internal.pu.DefaultProcessingUnitStatistics

All Implemented Interfaces:

ProcessingUnitStatistics, InternalProcessingUnitStatistics

public class DefaultProcessingUnitStatistics
extends Object
implements InternalProcessingUnitStatistics

This class performs 3 calculations on raw statistics: timeWindow, agentZones and instances calculations in order to transform the raw statisticsId into the requested statisticsId raw statisticsid read from pu instance (timestamp = now): ["mybean", "memory" , LastSampleTimeWindowStatisticsConfig, SingleInstanceStatisticsConfig("instance1"), ExactZoneConfig("zone1")] time calculated statisticsId (timestamp = now, but the calculator averaged the last 60 seconds): ["mybean", "memory" , AverageTimeWindowStatisticsConfig(60), SingleInstanceStatisticsConfig("instance1"), ExactZoneConfig("zone1")] zone calculated statisticsId (the zone is changed to reflect the requested statisticsId): ["mybean", "memory" , AverageTimeWindowStatisticsConfig(60), SingleInstanceStatisticsConfig("instance1"), AtLeastOneZoneConfig("zone1")] instances calculated statisticsId (the instances changed to reflect the average across all instances) This is also the requested statisticId: ["mybean", "memory" , AverageTimeWindowStatisticsConfig(60), AverageInstancesStatisticsConfig , AtLeastOneZoneConfig("zone1")]

Author:

Itai Frenkel

Constructor Summary

Constructors

Constructor and Description
DefaultProcessingUnitStatistics(long adminTimestamp, ProcessingUnitStatistics lastStatistics, int historySize)

Method Summary

Modifier and Type	Method and Description
void	addStatistics(ProcessingUnitStatisticsId statisticsId, Object statisticsValue) Adds raw statistics values
void	calculateStatistics(Iterable<ProcessingUnitStatisticsId> statisticsIds) Calculates new statistics based on previously added statistics and the specified statistics calculations and the list of instance UIDs
long	getAdminTimestamp()
ProcessingUnitStatistics	getPrevious()
Map<ProcessingUnitStatisticsId,Object>	getStatistics()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultProcessingUnitStatistics

public DefaultProcessingUnitStatistics(long adminTimestamp,
                                       ProcessingUnitStatistics lastStatistics,
                                       int historySize)

Method Detail

getAdminTimestamp

public long getAdminTimestamp()

Specified by:

getAdminTimestamp in interface ProcessingUnitStatistics

Returns:

a timestamp that is in sync with where the admin API is running. Can return -1 if the clocks have are not sync yet.

getPrevious

public ProcessingUnitStatistics getPrevious()

Specified by:

getPrevious in interface ProcessingUnitStatistics

Returns:

the previous processing unit statistics

getStatistics

public Map<ProcessingUnitStatisticsId,Object> getStatistics()

Specified by:

getStatistics in interface ProcessingUnitStatistics

Returns:

the statistics value for a single instance or aggregation of the complete cluster. The value can be Double , Number, String or any other type (Object).

See Also:

ProcessingUnitStatisticsId

addStatistics

public void addStatistics(ProcessingUnitStatisticsId statisticsId,
                          Object statisticsValue)

Description copied from interface: InternalProcessingUnitStatistics

Adds raw statistics values

Specified by:

addStatistics in interface InternalProcessingUnitStatistics

calculateStatistics

public void calculateStatistics(Iterable<ProcessingUnitStatisticsId> statisticsIds)

Description copied from interface: InternalProcessingUnitStatistics

Calculates new statistics based on previously added statistics and the specified statistics calculations and the list of instance UIDs

Specified by:

calculateStatistics in interface InternalProcessingUnitStatistics

See Also:

documentation

toString

public String toString()

Overrides:

toString in class Object