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.
Nested classes/interfaces inherited from interface org.eclipse.emf.common.notify.Adapter |
org.eclipse.emf.common.notify.Adapter.Internal |
Fields inherited from class com.ibm.rational.test.lt.execution.results.internal.data.adapters.RPTStatisticalAdapter |
defaultSynchronizer, facade, latestTarget, obsoleteNotifiers, parentAdapter, targets |
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 |
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
Aggregator
public Aggregator()
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
© Copyright IBM Corp. 2012. All rights reserved.