gCubeSystem
/
accounting-analytics-persistence-couchbase
Archived
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-analytics-persistence-couchbase@144017 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Alessandro Pieve 2017-02-21 14:02:24 +00:00
parent 4268109e10
commit 17493d3169
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
View File

@ -65,6 +65,7 @@ import com.couchbase.client.java.query.dsl.Expression;
import com.couchbase.client.java.query.dsl.Sort; import com.couchbase.client.java.query.dsl.Sort;
import com.couchbase.client.java.query.dsl.path.GroupByPath; import com.couchbase.client.java.query.dsl.path.GroupByPath;
import com.couchbase.client.java.query.dsl.path.OffsetPath; import com.couchbase.client.java.query.dsl.path.OffsetPath;
import com.couchbase.client.java.view.OnError;
import com.couchbase.client.java.view.ViewQuery; import com.couchbase.client.java.view.ViewQuery;
import com.couchbase.client.java.view.ViewResult; import com.couchbase.client.java.view.ViewResult;
import com.couchbase.client.java.view.ViewRow; import com.couchbase.client.java.view.ViewRow;
@ -1590,6 +1591,7 @@ AccountingPersistenceBackendQuery {
query.endKey(startKeyTmp); query.endKey(startKeyTmp);
query.descending(true); query.descending(true);
query.limit(1); query.limit(1);
query.onError(OnError.STOP);
} }
else{ else{
@ -1598,6 +1600,7 @@ AccountingPersistenceBackendQuery {
query.startKey(startKeyTmp); query.startKey(startKeyTmp);
query.endKey(endKeyTmp); query.endKey(endKeyTmp);
query.descending(false); query.descending(false);
query.onError(OnError.STOP);
} }
logger.trace("query row:{}",query.toString()); logger.trace("query row:{}",query.toString());
@ -1608,7 +1611,8 @@ AccountingPersistenceBackendQuery {
logger.error(e.getLocalizedMessage()); logger.error(e.getLocalizedMessage());
throw e; throw e;
} }
logger.trace("viewResult row:{}",viewResult.toString());
Map<String, Float> map = new HashMap<String, Float>(); Map<String, Float> map = new HashMap<String, Float>();
for (ViewRow row : viewResult) { for (ViewRow row : viewResult) {