You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by ot...@apache.org on 2009/04/15 00:03:04 UTC
svn commit: r764976 -
/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/model/file/BooleanPrefUserFileDataModel.java
Author: otis
Date: Tue Apr 14 22:03:03 2009
New Revision: 764976
URL: http://svn.apache.org/viewvc?rev=764976&view=rev
Log:
- Log when done reading a file and log the number of keys in the resulting map
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/model/file/BooleanPrefUserFileDataModel.java
Modified: lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/model/file/BooleanPrefUserFileDataModel.java
URL: http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/model/file/BooleanPrefUserFileDataModel.java?rev=764976&r1=764975&r2=764976&view=diff
==============================================================================
--- lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/model/file/BooleanPrefUserFileDataModel.java (original)
+++ lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/model/file/BooleanPrefUserFileDataModel.java Tue Apr 14 22:03:03 2009
@@ -77,8 +77,8 @@
this.lastModified = dataFile.lastModified();
this.reloadLock = new ReentrantLock();
- // Schedule next refresh
- timer.schedule(new RefreshTimerTask(), RELOAD_CHECK_INTERVAL_MS, RELOAD_CHECK_INTERVAL_MS);
+// // Schedule next refresh
+// timer.schedule(new RefreshTimerTask(), RELOAD_CHECK_INTERVAL_MS, RELOAD_CHECK_INTERVAL_MS);
}
protected void reload() {
@@ -109,6 +109,7 @@
processLine(line, data);
}
}
+ log.info("Done reading file: " + data.size());
}
/**
@@ -237,19 +238,19 @@
return "BooleanPrefUserFileDataModel[dataFile:" + dataFile + ']';
}
- private final class RefreshTimerTask extends TimerTask {
-
- @Override
- public void run() {
- if (loaded) {
- long newModified = dataFile.lastModified();
- if (newModified > lastModified) {
- log.debug("File has changed; reloading...");
- lastModified = newModified;
- reload();
- }
- }
- }
- }
+// private final class RefreshTimerTask extends TimerTask {
+//
+// @Override
+// public void run() {
+// if (loaded) {
+// long newModified = dataFile.lastModified();
+// if (newModified > lastModified) {
+// log.debug("File has changed; reloading...");
+// lastModified = newModified;
+// reload();
+// }
+// }
+// }
+// }
}
\ No newline at end of file