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 2014/12/22 16:36:11 UTC
[12/50] incubator-usergrid git commit: Use correct index name
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/UG-rest-test-framework-overhaul
Commit: 7000bd9c424a0ada98b03d0564385ae0b6933daf
Parents: 7dec37b
Author: Dave Johnson <dm...@apigee.com>
Authored: Fri Oct 31 14:00:44 2014 -0400
Committer: Dave Johnson <dm...@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 = {}",