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

Class Aggregator

  • java.lang.Object
    • com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter
      • 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.
    • 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
      • 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 -
      • 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
IBM Rational Performance Tester SDK

© Copyright IBM Corp. 2013. All rights reserved.