From 02c19e11edba852d5dc8d0973f01196b86ceec37 Mon Sep 17 00:00:00 2001
From: Eike Cochu <eike@cochu.com>
Date: Mon, 1 Aug 2016 20:50:01 +0200
Subject: [PATCH] updated
---
vipra-cmd/src/main/java/de/vipra/cmd/lda/Analyzer.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/vipra-cmd/src/main/java/de/vipra/cmd/lda/Analyzer.java b/vipra-cmd/src/main/java/de/vipra/cmd/lda/Analyzer.java
index d3d4e778..a8268867 100644
--- a/vipra-cmd/src/main/java/de/vipra/cmd/lda/Analyzer.java
+++ b/vipra-cmd/src/main/java/de/vipra/cmd/lda/Analyzer.java
@@ -18,6 +18,7 @@ import java.util.function.Consumer;
import org.bson.types.ObjectId;
+import de.vipra.cmd.Main;
import de.vipra.cmd.file.FilebaseIDDateIndex;
import de.vipra.cmd.file.FilebaseIDDateIndexEntry;
import de.vipra.cmd.file.FilebaseWindowIndex;
@@ -133,9 +134,14 @@ public class Analyzer {
final double smoothingFactor = 0.1;
int lastLength = printProgress(0, 0, iteration, maxIterationsLength, 0, modelConfig, 0);
int nextUpdate = 10;
+
+ List<Long> durations = new ArrayList<>(modelConfig.getDynamicMaxIterations());
+ Main.stats.start("dtm-iter");
while ((line = in.readLine()) != null) {
if (line.contains("EM iter")) {
+ Main.stats.stop("dtm-iter");
+ Main.stats.start("dtm-iter");
iteration++;
// calculate progress
@@ -145,6 +151,7 @@ public class Analyzer {
// calculate remaining duration
final long currentTime = System.nanoTime();
lastDuration = currentTime - lastStarted;
+ durations.add(lastDuration);
lastStarted = currentTime;
if (avgDuration == 0)
avgDuration = lastDuration;
@@ -162,6 +169,7 @@ public class Analyzer {
}
}
}
+ Main.stats.stop("dtm-iter");
ConsoleUtils.clearLine();
--
GitLab