From 38b9a12a669000a04807903f9bbe10d2e4f3339e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <stu114708@informatik.uni-kiel.de>
Date: Mon, 18 Jan 2016 18:57:30 +0100
Subject: [PATCH] add temporary printing to configuration
---
.../analysis/TraceAnalysisConfiguration.java | 21 ++++++++-----------
.../analysis/dev/DependencyCreatorStage.java | 5 +++--
2 files changed, 12 insertions(+), 14 deletions(-)
diff --git a/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java b/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java
index 464eca58..2c4c8c3d 100644
--- a/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java
+++ b/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java
@@ -9,9 +9,7 @@ import java.util.List;
import com.tinkerpop.blueprints.Graph;
-import kieker.analysis.dev.nestedgraph.NestedGraph;
-import kieker.analysis.dev.nestedgraphstages.NestedGraphFactory;
-import kieker.analysis.dev.nestedgraphstages.NestedGraphPrinterStage;
+import kieker.analysis.dev.DependencyCreatorStage;
import kieker.analysis.stage.tracediagnosis.AllowedRecordsFilter;
import kieker.analysis.stage.tracediagnosis.BeginEndOfMonitoringDetector;
import kieker.analysis.stage.tracediagnosis.OperationCallHandlerComposite;
@@ -32,7 +30,6 @@ import kieker.common.record.misc.KiekerMetadataRecord;
import teetime.framework.Configuration;
import teetime.stage.CollectorSink;
import teetime.stage.MultipleInstanceOfFilter;
-import teetime.stage.ObjectProducer;
import teetime.stage.basic.distributor.Distributor;
import teetime.stage.basic.distributor.strategy.CopyByReferenceStrategy;
@@ -98,8 +95,8 @@ public class TraceAnalysisConfiguration extends Configuration {
super.connectPorts(graphDistributor2.getNewOutputPort(), graphMLWriter2.getInputPort());
super.connectPorts(graphDistributor2.getNewOutputPort(), dotGraphWriter2.getInputPort());
- // DependencyCreatorStage dependencyCreatorStage = new DependencyCreatorStage();
- // super.connectPorts(aggregation.getOutputPort(), dependencyCreatorStage.getInputPort());
+ DependencyCreatorStage dependencyCreatorStage = new DependencyCreatorStage();
+ super.connectPorts(aggregation.getOutputPort(), dependencyCreatorStage.getInputPort());
/*
*
@@ -107,12 +104,12 @@ public class TraceAnalysisConfiguration extends Configuration {
*/
// TODO Temp Some examples for nested graphs
-
- final NestedGraphFactory nestedGraphFactory = new NestedGraphFactory();
- final ObjectProducer<NestedGraph<Graph>> nestedGraphProducerStage = new ObjectProducer<>(1, nestedGraphFactory);
- final NestedGraphPrinterStage nestedGraphPrinterStage = new NestedGraphPrinterStage();
-
- super.connectPorts(nestedGraphProducerStage.getOutputPort(), nestedGraphPrinterStage.getInputPort());
+ //
+ // final NestedGraphFactory nestedGraphFactory = new NestedGraphFactory();
+ // final ObjectProducer<NestedGraph<Graph>> nestedGraphProducerStage = new ObjectProducer<>(1, nestedGraphFactory);
+ // final NestedGraphPrinterStage nestedGraphPrinterStage = new NestedGraphPrinterStage();
+ //
+ // super.connectPorts(nestedGraphProducerStage.getOutputPort(), nestedGraphPrinterStage.getInputPort());
}
diff --git a/src/main/java/kieker/analysis/dev/DependencyCreatorStage.java b/src/main/java/kieker/analysis/dev/DependencyCreatorStage.java
index 5bc5739e..0b10e813 100644
--- a/src/main/java/kieker/analysis/dev/DependencyCreatorStage.java
+++ b/src/main/java/kieker/analysis/dev/DependencyCreatorStage.java
@@ -20,8 +20,9 @@ public class DependencyCreatorStage extends AbstractTransformation<AggregatedTra
// TODO Update Statistics
- // operationsDependency.printDependcies();
- // operationsDependency.printOperations();
+ // TODO Temporary final stage -> print result
+ operationsDependency.printDependenncies();
+ operationsDependency.printOperations();
this.getOutputPort().send(operationsDependency);
--
GitLab