IBM Rational Performance Tester SDK

com.ibm.rational.test.lt.execution.results.data.aggregation
Class Aggregator

java.lang.Object
  extended by com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter
      extended by com.ibm.rational.test.lt.execution.results.data.aggregation.Aggregator
All Implemented Interfaces:
com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator, org.eclipse.emf.common.notify.Adapter
Direct Known Subclasses:
com.ibm.rational.test.lt.execution.results.data.aggregation.StandardAggregator, TransferAggregator

public abstract class Aggregator
extends com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter
implements com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

extended by implementors of com.ibm.rational.test.lt.execution.results.Aggregator. An Aggregator receives data events from specific counters in the Statistical model and submits jobs to the AggregationJobRunner for processing at the conclusion of each sample interval.


Nested Class Summary
protected  class Aggregator.AggregationObservationAdapter
           
static class Aggregator.DataRepresentation
           
static class Aggregator.UnsmoothableDataException
           
 
Nested classes/interfaces inherited from interface org.eclipse.emf.common.notify.Adapter
org.eclipse.emf.common.notify.Adapter.Internal
 
Field Summary
protected  HashSet<org.eclipse.hyades.model.statistical.SDSnapshotObservation> activeNotifiers
           
protected  com.ibm.rational.test.lt.execution.results.data.collections.StringList basePathList
           
protected  boolean critical
           
protected  AggregationJob job
           
protected  AggregationJob jobForRecycle
           
protected  boolean started
           
protected  org.eclipse.hyades.model.statistical.SDCounterDescriptor[] targetDescriptor
           
protected  String targetNodeName
           
protected  com.ibm.rational.test.lt.execution.results.data.collections.StringList wildCardSubs
           
 
Fields inherited from class com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter
defaultSynchronizer, facade, latestTarget, obsoleteNotifiers, parentAdapter, targets
 
Constructor Summary
Aggregator()
           
 
Method Summary
 Aggregator.DataRepresentation _getSmoothedRepresentation(com.ibm.rational.test.lt.execution.results.view.data.RPTDataQuery dataset, org.eclipse.hyades.model.statistical.SDSnapshotObservation observation, com.ibm.rational.test.lt.execution.results.internal.data.aggregation.RPTTimeRange timeRange, int numPoints, double startTime, double endTime, String label)
           
 void cleanup()
           
 void clearData()
           
 double convertSampleTimeToSystemTime(double sampleTime)
           
 double convertToTimeRangeRelativeTime(double sampleTime)
           
static void debugStop(org.eclipse.hyades.model.statistical.SDDescriptor d)
           
static void debugStop(org.eclipse.hyades.model.statistical.SDSnapshotObservation obs)
           
static void debugStop(com.ibm.rational.test.lt.execution.results.data.collections.StringList pathUnderTest)
           
 Set<org.eclipse.hyades.model.statistical.SDSnapshotObservation> getActiveNotifiers()
           
 com.ibm.rational.test.lt.execution.results.data.collections.StringList getBasePathList()
           
 IConfigurationElement getConfigElement()
           
 String getDescriptorClassificationString()
           
abstract  com.ibm.rational.test.lt.execution.results.data.collections.StringList getFirstTargetPath()
           
abstract  AggregationJob getJob()
           
protected  String getJobProcessingNodeName(AggregationJob job)
           
 String getNodeName()
           
 com.ibm.rational.test.lt.execution.results.data.collections.ResultsList<org.eclipse.hyades.model.statistical.SDSnapshotObservation> getNotifiers()
           
 int getSampleIntervalWidth()
           
 int getSampleWindowIndex()
           
 Aggregator.DataRepresentation getSmoothedRepresentation(com.ibm.rational.test.lt.execution.results.view.data.RPTDataQuery dataset, org.eclipse.hyades.model.statistical.SDSnapshotObservation observation, com.ibm.rational.test.lt.execution.results.internal.data.aggregation.RPTTimeRange timeRange, int numPoints, double startTime, double endTime, String label)
           
 org.eclipse.hyades.model.statistical.SDCounterDescriptor getTargetDescriptor(int index)
           
 int getTargetDescriptorCount()
           
 org.eclipse.emf.common.util.EList<org.eclipse.hyades.model.statistical.SDCounterDescriptor> getTargetDescriptors()
           
 Object getValueAddedByNotifier(Object notifier)
           
protected  boolean initTargetDescriptors()
          infrastructure use only
 boolean isCritical()
           
 boolean isStarted()
           
protected  void logAddDataEvent(Object notifier, Object value, Double creationTime)
          infrastructure use only
 void notifyChanged(org.eclipse.emf.common.notify.Notification notification)
           
protected  void queJob()
          infrastructure use only
 void registerObservationAdapter(org.eclipse.hyades.model.statistical.SDSnapshotObservation newObservation)
           
protected static com.ibm.rational.test.lt.execution.results.data.collections.ResultsList resolveDescriptorPath(org.eclipse.hyades.model.statistical.SDDescriptor descriptor)
           
 void setBasePathList(com.ibm.rational.test.lt.execution.results.data.collections.StringList basePathList)
           
 void setConfigElement(IConfigurationElement element)
           
 void setCritical()
           
 void setRunBasedTime()
           
 void setTarget(org.eclipse.emf.common.notify.Notifier newTarget)
           
 void setTargetNodeName(String targetNodeName)
           
 void setTimeRange(com.ibm.rational.test.lt.execution.results.internal.data.aggregation.RPTTimeRange timeRange)
           
 void setWildCardSubs(com.ibm.rational.test.lt.execution.results.data.collections.StringList wildCardSubs)
           
protected  boolean siftForSpecificCollection(org.eclipse.hyades.model.statistical.SDCounterDescriptor newTarget, String[] counterPathEndElements, com.ibm.rational.test.lt.execution.results.data.collections.ResultsList collection)
          analyzes an SDCounterDescriptor to see if its model path ends with counterPathEndElements.
 boolean startup()
           
 boolean usesRunBasedTime()
           
 
Methods inherited from class com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter
adapt, adapt, adapt, adapt, getFacade, getParentAdapter, getTarget, getTargetCollection, getTimeRange, isAdapterForType, isObsolete, registerForCleanup, retainAtTimeRangeCompletion, setFacade, setObsolete, setObsolete, setObsolete, unAdapt
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
setFacade
 

Field Detail

wildCardSubs

protected com.ibm.rational.test.lt.execution.results.data.collections.StringList wildCardSubs

targetNodeName

protected String targetNodeName

targetDescriptor

protected org.eclipse.hyades.model.statistical.SDCounterDescriptor[] targetDescriptor

started

protected boolean started

job

protected AggregationJob job

jobForRecycle

protected AggregationJob jobForRecycle

activeNotifiers

protected HashSet<org.eclipse.hyades.model.statistical.SDSnapshotObservation> activeNotifiers

critical

protected boolean critical

basePathList

protected com.ibm.rational.test.lt.execution.results.data.collections.StringList basePathList
Constructor Detail

Aggregator

public Aggregator()
Method Detail

getDescriptorClassificationString

public String getDescriptorClassificationString()

getJob

public abstract AggregationJob getJob()
Specified by:
getJob in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getFirstTargetPath

public abstract com.ibm.rational.test.lt.execution.results.data.collections.StringList getFirstTargetPath()
Specified by:
getFirstTargetPath in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

cleanup

public void cleanup()
Specified by:
cleanup in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Overrides:
cleanup in class com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter

setConfigElement

public final void setConfigElement(IConfigurationElement element)
Specified by:
setConfigElement in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

notifyChanged

public void notifyChanged(org.eclipse.emf.common.notify.Notification notification)
Specified by:
notifyChanged in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Specified by:
notifyChanged in interface org.eclipse.emf.common.notify.Adapter

registerObservationAdapter

public final void registerObservationAdapter(org.eclipse.hyades.model.statistical.SDSnapshotObservation newObservation)
Specified by:
registerObservationAdapter in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

setTarget

public void setTarget(org.eclipse.emf.common.notify.Notifier newTarget)
Specified by:
setTarget in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Specified by:
setTarget in interface org.eclipse.emf.common.notify.Adapter
Overrides:
setTarget in class com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter

setTargetNodeName

public void setTargetNodeName(String targetNodeName)
Specified by:
setTargetNodeName in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getTargetDescriptors

public org.eclipse.emf.common.util.EList<org.eclipse.hyades.model.statistical.SDCounterDescriptor> getTargetDescriptors()
Specified by:
getTargetDescriptors in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

startup

public boolean startup()
Specified by:
startup in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

setWildCardSubs

public final void setWildCardSubs(com.ibm.rational.test.lt.execution.results.data.collections.StringList wildCardSubs)
Specified by:
setWildCardSubs in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

initTargetDescriptors

protected boolean initTargetDescriptors()
infrastructure use only

Returns:
boolean

getConfigElement

public final IConfigurationElement getConfigElement()
Specified by:
getConfigElement in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getTargetDescriptor

public final org.eclipse.hyades.model.statistical.SDCounterDescriptor getTargetDescriptor(int index)
Specified by:
getTargetDescriptor in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

isStarted

public final boolean isStarted()
Specified by:
isStarted in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

logAddDataEvent

protected void logAddDataEvent(Object notifier,
                               Object value,
                               Double creationTime)
infrastructure use only

Parameters:
notifier -
value -
creationTime -

getJobProcessingNodeName

protected String getJobProcessingNodeName(AggregationJob job)

queJob

protected final void queJob()
infrastructure use only


clearData

public void clearData()
Specified by:
clearData in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getNotifiers

public final com.ibm.rational.test.lt.execution.results.data.collections.ResultsList<org.eclipse.hyades.model.statistical.SDSnapshotObservation> getNotifiers()
Specified by:
getNotifiers in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getValueAddedByNotifier

public final Object getValueAddedByNotifier(Object notifier)
Specified by:
getValueAddedByNotifier in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

siftForSpecificCollection

protected final boolean siftForSpecificCollection(org.eclipse.hyades.model.statistical.SDCounterDescriptor newTarget,
                                                  String[] counterPathEndElements,
                                                  com.ibm.rational.test.lt.execution.results.data.collections.ResultsList collection)
analyzes an SDCounterDescriptor to see if its model path ends with counterPathEndElements. If this check yields true, then the descriptor is added to "collection". This mechanism is useful for aggregators who need a way of quickly accessing dependencies of a certain category. It is very important that collection be cleaned up at the end of the run when the cleanup api is called.

Parameters:
newTarget -
counterPathEndElements -
collection -

getTargetDescriptorCount

public final int getTargetDescriptorCount()
Specified by:
getTargetDescriptorCount in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

isCritical

public final boolean isCritical()
Specified by:
isCritical in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

setCritical

public final void setCritical()
Specified by:
setCritical in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

setRunBasedTime

public final void setRunBasedTime()
Specified by:
setRunBasedTime in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

usesRunBasedTime

public final boolean usesRunBasedTime()
Specified by:
usesRunBasedTime in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

convertSampleTimeToSystemTime

public final double convertSampleTimeToSystemTime(double sampleTime)
                                           throws com.ibm.rpa.statistical.ModelFacadeException
Specified by:
convertSampleTimeToSystemTime in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Throws:
com.ibm.rpa.statistical.ModelFacadeException

convertToTimeRangeRelativeTime

public final double convertToTimeRangeRelativeTime(double sampleTime)
                                            throws com.ibm.rpa.statistical.ModelFacadeException
Specified by:
convertToTimeRangeRelativeTime in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Throws:
com.ibm.rpa.statistical.ModelFacadeException

getSampleIntervalWidth

public final int getSampleIntervalWidth()
                                 throws com.ibm.rpa.statistical.ModelFacadeException
Specified by:
getSampleIntervalWidth in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Throws:
com.ibm.rpa.statistical.ModelFacadeException

getNodeName

public final String getNodeName()
Specified by:
getNodeName in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getSampleWindowIndex

public int getSampleWindowIndex()
Specified by:
getSampleWindowIndex in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

setTimeRange

public void setTimeRange(com.ibm.rational.test.lt.execution.results.internal.data.aggregation.RPTTimeRange timeRange)
Specified by:
setTimeRange in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Overrides:
setTimeRange in class com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter

resolveDescriptorPath

protected static com.ibm.rational.test.lt.execution.results.data.collections.ResultsList resolveDescriptorPath(org.eclipse.hyades.model.statistical.SDDescriptor descriptor)

debugStop

public static void debugStop(org.eclipse.hyades.model.statistical.SDDescriptor d)

debugStop

public static void debugStop(org.eclipse.hyades.model.statistical.SDSnapshotObservation obs)

debugStop

public static void debugStop(com.ibm.rational.test.lt.execution.results.data.collections.StringList pathUnderTest)

getActiveNotifiers

public Set<org.eclipse.hyades.model.statistical.SDSnapshotObservation> getActiveNotifiers()
Specified by:
getActiveNotifiers in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator

getBasePathList

public com.ibm.rational.test.lt.execution.results.data.collections.StringList getBasePathList()

setBasePathList

public void setBasePathList(com.ibm.rational.test.lt.execution.results.data.collections.StringList basePathList)

getSmoothedRepresentation

public Aggregator.DataRepresentation getSmoothedRepresentation(com.ibm.rational.test.lt.execution.results.view.data.RPTDataQuery dataset,
                                                               org.eclipse.hyades.model.statistical.SDSnapshotObservation observation,
                                                               com.ibm.rational.test.lt.execution.results.internal.data.aggregation.RPTTimeRange timeRange,
                                                               int numPoints,
                                                               double startTime,
                                                               double endTime,
                                                               String label)
                                                        throws Aggregator.UnsmoothableDataException
Specified by:
getSmoothedRepresentation in interface com.ibm.rational.test.lt.execution.results.data.aggregation.IAggregator
Throws:
Aggregator.UnsmoothableDataException

_getSmoothedRepresentation

public Aggregator.DataRepresentation _getSmoothedRepresentation(com.ibm.rational.test.lt.execution.results.view.data.RPTDataQuery dataset,
                                                                org.eclipse.hyades.model.statistical.SDSnapshotObservation observation,
                                                                com.ibm.rational.test.lt.execution.results.internal.data.aggregation.RPTTimeRange timeRange,
                                                                int numPoints,
                                                                double startTime,
                                                                double endTime,
                                                                String label)
                                                         throws Aggregator.UnsmoothableDataException
Throws:
Aggregator.UnsmoothableDataException

IBM Rational Performance Tester SDK

© Copyright IBM Corp. 2012. All rights reserved.