From 5af822f7ab2caca28a8405ac1eb348a85179b96b Mon Sep 17 00:00:00 2001 From: j2blake Date: Wed, 6 Nov 2013 15:57:21 -0500 Subject: [PATCH] VIVO-469 print progress messages while looking for URIs to re-index. --- .../webapp/search/indexing/IndexBuilder.java | 23 +++++++++++++++---- 1 file changed, 18 insertions(+), 5 deletions(-) diff --git a/webapp/src/edu/cornell/mannlib/vitro/webapp/search/indexing/IndexBuilder.java b/webapp/src/edu/cornell/mannlib/vitro/webapp/search/indexing/IndexBuilder.java index 0d7fea706..69e2ba3ee 100644 --- a/webapp/src/edu/cornell/mannlib/vitro/webapp/search/indexing/IndexBuilder.java +++ b/webapp/src/edu/cornell/mannlib/vitro/webapp/search/indexing/IndexBuilder.java @@ -281,11 +281,24 @@ public class IndexBuilder extends VitroBackgroundThread { //keep uris unique by using a HashSet Collection urisToUpdate = new HashSet(); - for( Statement stmt : getAndClearChangedStmts() ){ - for( StatementToURIsToUpdate stu : stmtToURIsToIndexFunctions ){ - urisToUpdate.addAll( stu.findAdditionalURIsToIndex(stmt) ); - } - } + Statement[] changedStatements = getAndClearChangedStmts(); + int howManyChanges = changedStatements.length; + + if (howManyChanges > 100) { + log.info("Finding URIs that are affected by " + howManyChanges + + " changed statements."); + } + + for (int i = 0; i < howManyChanges; i++) { + Statement stmt = changedStatements[i]; + for (StatementToURIsToUpdate stu : stmtToURIsToIndexFunctions) { + urisToUpdate.addAll(stu.findAdditionalURIsToIndex(stmt)); + } + if ((i > 0) && (i % 1000 == 0)) { + log.info("Processed " + i + " changed statements; found " + + urisToUpdate.size() + " affected URIs."); + } + } //inform StatementToURIsToUpdate that they are done for( StatementToURIsToUpdate stu : stmtToURIsToIndexFunctions ) {