You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/06/30 23:23:15 UTC
incubator-usergrid git commit: change the way index is called in
reindex opp
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o-dev a30670a50 -> 6b829cae6
change the way index is called in reindex opp
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/6b829cae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/6b829cae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/6b829cae
Branch: refs/heads/two-dot-o-dev
Commit: 6b829cae697cfb508b8aa673ff6d45bb3177d4c8
Parents: a30670a
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Jun 30 15:23:06 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Jun 30 15:23:06 2015 -0600
----------------------------------------------------------------------
.../usergrid/corepersistence/index/ReIndexServiceImpl.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6b829cae/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReIndexServiceImpl.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReIndexServiceImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReIndexServiceImpl.java
index 194e187..5ee545e 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReIndexServiceImpl.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReIndexServiceImpl.java
@@ -126,11 +126,12 @@ public class ReIndexServiceImpl implements ReIndexService {
//for each edge, create our scope and index on it
.doOnNext( edge -> {
- final EntityIndexOperation entityIndexOperation = new EntityIndexOperation( edge.getApplicationScope(), edge.getEdge().getTargetNode(), modifiedSince );
- logger.info( "Queueing {}", entityIndexOperation );
+ if(logger.isInfoEnabled()) {
+ logger.info("Queueing {} {}", edge.getApplicationScope(), edge.getEdge().getTargetNode());
+ }
- indexService.index(entityIndexOperation.getApplicationScope(),entityIndexOperation.getId(), modifiedSince);
+ indexService.index(edge.getApplicationScope(),edge.getEdge().getTargetNode(), modifiedSince);
} );