diff --git a/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java b/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java index 464eca58d955f67f37fcc4ce8fdfc230ff7f92db..2c4c8c3dbda733bd4f0bf0c0b0c73061318d681e 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 5bc5739eb18d4119e9928c6fceaf044bfbcc44e6..0b10e81332ca2379454ee2e429eb1dbb3723c18d 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);