Add Support for Predictive Scaling

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd.adjustment/src/org/palladiosimulator/analyzer/slingshot/behavior/spd/adjustment/qvto/util/ModelTransformationCache.java

@@ -11,118 +11,119 @@
 import org.palladiosimulator.analyzer.slingshot.behavior.spd.adjustment.qvto.QVToModelTransformation;
 
 /**
- * This cache implementation is used to store QVTo transformations (in terms
- * of {@link TransformationData} objects) that can be executed by QVTo executors
- * during reconfigurations. To store a transformation in the cache, its corresponding
- * {@link URI} is used as tag.
+ * This cache implementation is used to store QVTo transformations (in terms of
+ * {@link TransformationData} objects) that can be executed by QVTo executors during
+ * reconfigurations. To store a transformation in the cache, its corresponding {@link URI} is used
+ * as tag.
  * 
  * @author Florian Rosenthal
  *
  */
 public class ModelTransformationCache {
 
-	private static final Logger LOGGER = Logger.getLogger(ModelTransformationCache.class);
-	
-	private final Map<URI, QVToModelTransformation> cache;
-	private final ModelTransformationFactory modelTransformationFactory;
-	
-	/**
-	 * Initializes a new instance of the {@link ModelTransformationCache} class.
-	 * 
-	 * @param initialTransformations
-	 *            A set of transformation {@link URI URIs} that shall be stored
-	 *            in the cache, might be empty.
-	 */
-	public ModelTransformationCache(final URI... initialTransformations) {
-		this.cache = new HashMap<>();
-		this.modelTransformationFactory = new ModelTransformationFactory();
-		store(initialTransformations);
-	}
-	
-	/**
-	 * Stores the QVTo transformations specified by the given URIs in the cache.
-	 * 
-	 * @param transformationUris
-	 *            A set of {@link URI URIs} that point to QVTo transformations.
-	 * @throws NullPointerException
-	 *             In case {@code transformationUris == null}.
-	 * @throws IllegalArgumentException
-	 *             In case any of the transformations is already present in the
-	 *             cache.
-	 */
-	public final void store(final URI... transformationUris) {
-		final URI[] uris = Objects.requireNonNull(transformationUris);
-		for (final URI transformationUri : uris) {
-			if (contains(transformationUri)) {
-				throw new IllegalArgumentException("Transformation " + transformationUri + " already in store.");
-			}
-			LOGGER.debug("Cache reconfiguration rule \"" + transformationUri + "\"");
-			this.cache.put(transformationUri, this.modelTransformationFactory.createModelTransformation(transformationUri));
-		}
-	}
-	
-	/**
-	 * Attempts to retrieve the QVTo transformation that is associated with the
-	 * given URI from the cache.
-	 * 
-	 * @param transformationUri
-	 *            A {@link URI} that points to a QVTo transformation.
-	 * @return The {@link TransformationData} of the transformation, or
-	 *         {@code null} if it is not present in the cache.
-	 * @throws NullPointerException
-	 *             In case the given URI is {@code null}.
-	 * @see #contains(URI)
-	 */
-	public Optional<QVToModelTransformation> get(final URI transformationUri) {
-		if (!this.contains(transformationUri)) {
-			this.store(transformationUri);
-		}
-		return Optional.ofNullable(this.cache.get(Objects.requireNonNull(transformationUri)));
-	}
-	
-	/**
+    private static final Logger LOGGER = Logger.getLogger(ModelTransformationCache.class);
+
+    private final Map<URI, QVToModelTransformation> cache;
+    private final ModelTransformationFactory modelTransformationFactory;
+
+    /**
+     * Initializes a new instance of the {@link ModelTransformationCache} class.
+     * 
+     * @param initialTransformations
+     *            A set of transformation {@link URI URIs} that shall be stored in the cache, might
+     *            be empty.
+     */
+    public ModelTransformationCache(final URI... initialTransformations) {
+        this.cache = new HashMap<>();
+        this.modelTransformationFactory = new ModelTransformationFactory();
+        store(initialTransformations);
+    }
+
+    /**
+     * Stores the QVTo transformations specified by the given URIs in the cache.
+     * 
+     * @param transformationUris
+     *            A set of {@link URI URIs} that point to QVTo transformations.
+     * @throws NullPointerException
+     *             In case {@code transformationUris == null}.
+     * @throws IllegalArgumentException
+     *             In case any of the transformations is already present in the cache.
+     */
+    public final void store(final URI... transformationUris) {
+        final URI[] uris = Objects.requireNonNull(transformationUris);
+        for (final URI transformationUri : uris) {
+            if (contains(transformationUri)) {
+                throw new IllegalArgumentException("Transformation " + transformationUri + " already in store.");
+            }
+            LOGGER.debug("Cache reconfiguration rule \"" + transformationUri + "\"");
+            this.cache.put(transformationUri,
+                    this.modelTransformationFactory.createModelTransformation(transformationUri));
+        }
+    }
+
+    /**
+     * Attempts to retrieve the QVTo transformation that is associated with the given URI from the
+     * cache.
+     * 
+     * @param transformationUri
+     *            A {@link URI} that points to a QVTo transformation.
+     * @return The {@link TransformationData} of the transformation, or {@code null} if it is not
+     *         present in the cache.
+     * @throws NullPointerException
+     *             In case the given URI is {@code null}.
+     * @see #contains(URI)
+     */
+    public Optional<QVToModelTransformation> get(final URI transformationUri) {
+        if (!this.contains(transformationUri)) {
+            this.store(transformationUri);
+        }
+        return Optional.ofNullable(this.cache.get(Objects.requireNonNull(transformationUri)));
+    }
+
+    /**
      * Removes the QVTo transformations specified by the given URIs from this cache, if present.
      * 
      * @param transformationUris
      *            A set of {@link URI URIs} that point to QVTo transformations.
      * @throws NullPointerException
      *             In case any of the given uris is {@code null}.
      */
-	public final void remove(final URI... transformationUris) {
-		final URI[] uris = Objects.requireNonNull(transformationUris);
-		Arrays.stream(uris).map(Objects::requireNonNull).forEach(this.cache::remove);
-	}
-
-	/**
-	 * Gets whether the QVTo transformation which the given URI points to, is
-	 * currently in the cache.
-	 * 
-	 * @param transformationUri
-	 *            A {@link URI} that points to a QVTo transformation.
-	 * @return {@code true}, iff the transformation is stored, {@code false}
-	 *         otherwise
-	 * 
-	 * @throws NullPointerException
-	 *             In case the given URI is {@code null}.
-	 */
-	public boolean contains(final URI transformationUri) {
-		return this.cache.containsKey(Objects.requireNonNull(transformationUri));
-	}
-
-	/**
-	 * Gets all the transformations, in terms of the respective
-	 * {@link TransformationData} currently stored in this cache.
-	 * 
-	 * @return An {@link Iterable} of all the stored transformations.
-	 */
-	public Iterable<QVToModelTransformation> getAll() {
-		return this.cache.values();
-	}
-
-	/**
-	 * Clears the cache, that is, all content is discarded.
-	 */
-	public void clear() {
-		this.cache.clear();
-	}
+    public final void remove(final URI... transformationUris) {
+        final URI[] uris = Objects.requireNonNull(transformationUris);
+        Arrays.stream(uris)
+            .map(Objects::requireNonNull)
+            .forEach(this.cache::remove);
+    }
+
+    /**
+     * Gets whether the QVTo transformation which the given URI points to, is currently in the
+     * cache.
+     * 
+     * @param transformationUri
+     *            A {@link URI} that points to a QVTo transformation.
+     * @return {@code true}, iff the transformation is stored, {@code false} otherwise
+     * 
+     * @throws NullPointerException
+     *             In case the given URI is {@code null}.
+     */
+    public boolean contains(final URI transformationUri) {
+        return this.cache.containsKey(Objects.requireNonNull(transformationUri));
+    }
+
+    /**
+     * Gets all the transformations, in terms of the respective {@link TransformationData} currently
+     * stored in this cache.
+     * 
+     * @return An {@link Iterable} of all the stored transformations.
+     */
+    public Iterable<QVToModelTransformation> getAll() {
+        return this.cache.values();
+    }
+
+    /**
+     * Clears the cache, that is, all content is discarded.
+     */
+    public void clear() {
+        this.cache.clear();
+    }
 }

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd.data/META-INF/MANIFEST.MF

@@ -7,5 +7,6 @@ Automatic-Module-Name: org.palladiosimulator.analyzer.slingshot.behavior.spd.dat
 Bundle-RequiredExecutionEnvironment: JavaSE-17
 Require-Bundle: org.palladiosimulator.analyzer.slingshot.common;bundle-version="1.0.0",
  org.palladiosimulator.spd,
- org.palladiosimulator.monitorrepository
+ org.palladiosimulator.monitorrepository,
+ org.palladiosimulator.analyzer.slingshot.eventdriver
 Export-Package: org.palladiosimulator.analyzer.slingshot.behavior.spd.data

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd.data/src/org/palladiosimulator/analyzer/slingshot/behavior/spd/data/ModelAdjustmentRequested.java

@@ -6,24 +6,21 @@
 import org.palladiosimulator.spd.ScalingPolicy;
 
 /**
- * Tells that a certain adjustment to the PCM model is requested. An adjustor
- * module can then perform these adjustments.
- * <br>
- * This event holds the enacted scaling policy that was fired as well as
- * the target group.
+ * Tells that a certain adjustment to the PCM model is requested. An adjustor module can then
+ * perform these adjustments. <br>
+ * This event holds the enacted scaling policy that was fired as well as the target group.
  * 
  * @author Julijan Katic
  */
 public final class ModelAdjustmentRequested extends AbstractSimulationEvent implements SpdBasedEvent {
 
-	private final ScalingPolicy scalingPolicy;
-
-	public ModelAdjustmentRequested(final ScalingPolicy scalingPolicy) {
-		this.scalingPolicy = Objects.requireNonNull(scalingPolicy);
-	}
-
-	public ScalingPolicy getScalingPolicy() {
-		return this.scalingPolicy;
-	}
-
+    private final ScalingPolicy scalingPolicy;
+
+    public ModelAdjustmentRequested(final ScalingPolicy scalingPolicy) {
+        this.scalingPolicy = Objects.requireNonNull(scalingPolicy);
+    }
+
+    public ScalingPolicy getScalingPolicy() {
+        return this.scalingPolicy;
+    }
 }

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd.data/src/org/palladiosimulator/analyzer/slingshot/behavior/spd/data/RepeatedSimulationTimeReached.java

@@ -0,0 +1,35 @@
+package org.palladiosimulator.analyzer.slingshot.behavior.spd.data;
+
+import org.palladiosimulator.analyzer.slingshot.common.events.AbstractSimulationEvent;
+
+/**
+ * An event that is scheduled at an exact simulation time and repeats on a schedule. In context of
+ * SPD, this is needed especially for predictive triggers that recompute some measures on a
+ * schedule.
+ * 
+ * This event also carries a necessary target group (identifier) in order to correctly identify
+ * whether this event belongs to the right scaling policy.
+ * 
+ * @author Jens Berberich, Julijan Katic
+ */
+public class RepeatedSimulationTimeReached extends AbstractSimulationEvent implements SpdBasedEvent {
+
+    private final String targetGroupId;
+    private double repetitionTime;
+
+    public RepeatedSimulationTimeReached(String targetGroupId, double simulationTime, double delay,
+            double repetitionTime) {
+        super(delay);
+        this.targetGroupId = targetGroupId;
+        this.setTime(simulationTime);
+        this.repetitionTime = repetitionTime;
+    }
+
+    public double getRepetitionTime() {
+        return repetitionTime;
+    }
+
+    public String getTargetGroupId() {
+        return targetGroupId;
+    }
+}

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd.data/src/org/palladiosimulator/analyzer/slingshot/behavior/spd/data/SimulationTimeReached.java

@@ -17,7 +17,7 @@
  * 
  * @author Julijan Katic
  */
-public final class SimulationTimeReached extends AbstractSimulationEvent implements SpdBasedEvent {
+public class SimulationTimeReached extends AbstractSimulationEvent implements SpdBasedEvent {
 
 	private final String targetGroupId;
 

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd/META-INF/MANIFEST.MF

@@ -3,6 +3,7 @@ Bundle-ManifestVersion: 2
 Bundle-Name: Spd
 Bundle-SymbolicName: org.palladiosimulator.analyzer.slingshot.behavior.spd;singleton:=true
 Bundle-Version: 1.0.0.qualifier
+Import-Package: org.apache.commons.math3.stat.regression
 Automatic-Module-Name: org.palladiosimulator.analyzer.slingshot.behavior.spd
 Bundle-RequiredExecutionEnvironment: JavaSE-17
 Require-Bundle: org.palladiosimulator.analyzer.slingshot.core;bundle-version="1.0.0",
@@ -13,4 +14,6 @@ Require-Bundle: org.palladiosimulator.analyzer.slingshot.core;bundle-version="1.
  org.palladiosimulator.analyzer.slingshot.ui.events;bundle-version="1.0.0",
  org.palladiosimulator.analyzer.slingshot.workflow.events;bundle-version="1.0.0",
  org.palladiosimulator.pcm.edp2.measuringpoint,
- org.palladiosimulator.spd.semantic
+ org.palladiosimulator.spd.semantic,
+ org.palladiosimulator.spd,
+ org.palladiosimulator.spd.measuringpoint

bundles/org.palladiosimulator.analyzer.slingshot.behavior.spd/src/org/palladiosimulator/analyzer/slingshot/behavior/spd/interpreter/ModelInterpreter.java

@@ -0,0 +1,51 @@
+package org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter;
+
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.aggregator.AnyStimulusAggregator;
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.aggregator.ManagedElementAggregator;
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.aggregator.ModelAggregatorWrapper;
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.model.FuzzyQLearningModelEvaluator;
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.model.FuzzySARSAModelEvaluator;
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.model.ModelEvaluator;
+import org.palladiosimulator.analyzer.slingshot.behavior.spd.interpreter.entity.model.RandomModelEvaluator;
+import org.palladiosimulator.spd.models.FuzzyQLearningModel;
+import org.palladiosimulator.spd.models.FuzzySARSAModel;
+import org.palladiosimulator.spd.models.LearningBasedModel;
+import org.palladiosimulator.spd.models.RandomModel;
+import org.palladiosimulator.spd.models.util.ModelsSwitch;
+import org.palladiosimulator.spd.triggers.AGGREGATIONMETHOD;
+import org.palladiosimulator.spd.triggers.stimuli.ManagedElementsStateStimulus;
+import org.palladiosimulator.spd.triggers.stimuli.Stimulus;
+
+public class ModelInterpreter extends ModelsSwitch<ModelEvaluator> {
+
+    @SuppressWarnings("rawtypes")
+    public ModelAggregatorWrapper getAggregatorForStimulus(final Stimulus stimulus, final LearningBasedModel model) {
+        if (stimulus instanceof final ManagedElementsStateStimulus managedElementsStateStimulus) {
+            return new ManagedElementAggregator<>(managedElementsStateStimulus, model.getInterval());
+        } else {
+            // TODO currently using average aggregation by default for non-aggregated
+            // stimuli, this might need to be changed
+            return this.getAggregatorForStimulus(stimulus, model, AGGREGATIONMETHOD.AVERAGE);
+        }
+    }
+
+    public <T extends Stimulus> ModelAggregatorWrapper<T> getAggregatorForStimulus(final T stimulus,
+            final LearningBasedModel model, final AGGREGATIONMETHOD aggregationMethod) {
+        return new AnyStimulusAggregator<>(stimulus, model.getInterval(), aggregationMethod);
+    }
+
+    @Override
+    public ModelEvaluator caseRandomModel(final RandomModel model) {
+        return new RandomModelEvaluator(model);
+    }
+
+    @Override
+    public ModelEvaluator caseFuzzySARSAModel(FuzzySARSAModel model) {
+        return new FuzzySARSAModelEvaluator(model, this);
+    }
+
+    @Override
+    public ModelEvaluator caseFuzzyQLearningModel(FuzzyQLearningModel model) {
+        return new FuzzyQLearningModelEvaluator(model, this);
+    }
+}