Add statistics to operations in dependency model

src/main/java/kieker/analysis/TraceAnalysisConfiguration.java

@@ -10,6 +10,7 @@ import java.util.List;
 import com.tinkerpop.blueprints.Graph;
 
 import kieker.analysis.dev.DependencyCreatorStage;
+import kieker.analysis.dev.DependencyStatisticsDecoratorStage;
 import kieker.analysis.stage.tracediagnosis.AllowedRecordsFilter;
 import kieker.analysis.stage.tracediagnosis.BeginEndOfMonitoringDetector;
 import kieker.analysis.stage.tracediagnosis.OperationCallHandlerComposite;
@@ -100,7 +101,9 @@ public class TraceAnalysisConfiguration extends Configuration {
 		super.connectPorts(graphDistributor2.getNewOutputPort(), dotGraphWriter2.getInputPort());
 
 		DependencyCreatorStage dependencyCreatorStage = new DependencyCreatorStage();
+		DependencyStatisticsDecoratorStage dependencyStatisticsDecoratorStage = new DependencyStatisticsDecoratorStage();
 		super.connectPorts(aggregatedTraceDistributor.getNewOutputPort(), dependencyCreatorStage.getInputPort());
+		super.connectPorts(dependencyCreatorStage.getOutputPort(), dependencyStatisticsDecoratorStage.getInputPort());
 
 		/*
 		 *

src/main/java/kieker/analysis/dev/DependencyCreatorStage.java

@@ -18,12 +18,6 @@ public class DependencyCreatorStage extends AbstractTransformation<AggregatedTra
 	@Override
 	public void onTerminating() throws Exception { // NOPMD (the throws clause is forced by the framework)
 
-		// TODO Update Statistics
-
-		// TODO Temporary final stage -> print result
-		operationsDependency.printDependenncies();
-		operationsDependency.printOperations();
-
 		this.getOutputPort().send(operationsDependency);
 
 		super.onTerminating();

src/main/java/kieker/analysis/dev/DependencyStatisticsDecorator.java

 package kieker.analysis.dev;
 
+import java.util.List;
+import java.util.stream.Collectors;
+
+import kieker.analysis.traceanalysisdomain.AggregatedOperationCall;
+import kieker.analysis.traceanalysisutil.Statistics;
+import kieker.analysis.traceanalysisutil.StatisticsUtility;
+
+/**
+ * @author Sören Henning
+ *
+ */
+// TODO Maybe make static
 public class DependencyStatisticsDecorator {
 
 	public void decorate(final OperationsDependency operationsDependency) {
 
+		for (AggregatedOperationCall operation : operationsDependency.getOperations()) {
+
+			List<Long> durations = operation.getBaseOperationCalls().stream()
+					.map(call -> call.getDuration()).collect(Collectors.toList());
+
+			Statistics statistics = StatisticsUtility.calculateStatistics(durations);
+
+			operation.setTotalDuration(statistics.getTotalDuration());
+			operation.setMaxDuration(statistics.getMaxDuration());
+			operation.setMinDuration(statistics.getMinDuration());
+			operation.setMeanDuration(statistics.getMeanDuration());
+			operation.setMedianDuration(statistics.getMedianDuration());
+
+		}
+
 	}
 
 }

src/main/java/kieker/analysis/dev/DependencyStatisticsDecoratorStage.java

@@ -2,14 +2,24 @@ package kieker.analysis.dev;
 
 import teetime.stage.basic.AbstractTransformation;
 
+/**
+ * @author Sören Henning
+ *
+ */
 public class DependencyStatisticsDecoratorStage extends AbstractTransformation<OperationsDependency, OperationsDependency> {
 
+	private final DependencyStatisticsDecorator statisticsDecorator = new DependencyStatisticsDecorator();
+
 	@Override
-	protected void execute(final OperationsDependency element) {
+	protected void execute(final OperationsDependency operationsDependency) {
+
+		statisticsDecorator.decorate(operationsDependency);
 
-		// TODO
+		// TODO Temporary final stage -> print result
+		operationsDependency.printDependenncies();
+		operationsDependency.printOperations();
 
-		this.getOutputPort().send(element);
+		this.getOutputPort().send(operationsDependency);
 
 	}