usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject [13/50] incubator-usergrid git commit: Use correct index name
Date Mon, 15 Dec 2014 18:31:57 GMT
Use correct index name


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/7000bd9c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/7000bd9c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/7000bd9c

Branch: refs/heads/two-dot-o
Commit: 7000bd9c424a0ada98b03d0564385ae0b6933daf
Parents: 7dec37b
Author: Dave Johnson <dmjohnson@apigee.com>
Authored: Fri Oct 31 14:00:44 2014 -0400
Committer: Dave Johnson <dmjohnson@apigee.com>
Committed: Fri Oct 31 14:00:44 2014 -0400

----------------------------------------------------------------------
 .../usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/7000bd9c/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java
b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java
index ca7f666..aedee2b 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java
@@ -203,7 +203,7 @@ public class EsEntityIndexBatchImpl implements EntityIndexBatch {
         TermQueryBuilder tqb = QueryBuilders.termQuery(
             STRING_PREFIX + ENTITYID_FIELDNAME, entityId.getUuid().toString().toLowerCase());
 
-        DeleteByQueryResponse response = client.prepareDeleteByQuery("test")
+        DeleteByQueryResponse response = client.prepareDeleteByQuery( indexName )
             .setQuery( tqb ).execute().actionGet();
 
         logger.debug("Deleted entity {}:{} from all index scopes with response status = {}",

@@ -222,7 +222,7 @@ public class EsEntityIndexBatchImpl implements EntityIndexBatch {
                          ( STRING_PREFIX + ENTITYID_FIELDNAME,entity.getId().getUuid().toString().toLowerCase()
),
                          FilterBuilders.rangeFilter("version").lt( entity.getId().getUuid().timestamp()
));
 
-        DeleteByQueryResponse response = client.prepareDeleteByQuery("test")
+        DeleteByQueryResponse response = client.prepareDeleteByQuery( indexName )
                                                .setQuery( fqb ).execute().actionGet();
 
         logger.debug("Deleted entity {}:{} from all index scopes with response status = {}",


Mime
View raw message