From 3df69197ec7c801b4271401b7218bd6256853816 Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Tue, 29 Mar 2016 08:58:33 +0000
Subject: [PATCH] refs #1665: Create Accounting Analytics Persistence CouchBase
 https://support.d4science.org/issues/1665

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-analytics-persistence-couchbase@126337 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 .../AccountingPersistenceQueryCouchBase.java  | 21 +++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java b/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
index 0a6e901..62d32cc 100644
--- a/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
+++ b/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
@@ -434,8 +434,25 @@ public class AccountingPersistenceQueryCouchBase implements
 			Class<? extends AggregatedRecord<?, ?>> clz,
 			TemporalConstraint temporalConstraint, List<Filter> filters,
 			String topKey, String orderingProperty) throws Exception {
-		// TODO Auto-generated method stub
-		return null;
+		
+		SortedMap<NumberedFilter, SortedMap<Calendar, Info>> ret = 
+				new TreeMap<>();
+		
+		SortedSet<NumberedFilter> top = getNextPossibleValues(clz, 
+				temporalConstraint, filters, topKey, orderingProperty);
+		
+		for(NumberedFilter nf : top){
+			filters.add(nf);
+			
+			SortedMap<Calendar, Info> map = 
+					mapReduceQuery(clz, temporalConstraint, filters);
+			
+			ret.put(nf, map);
+			
+			filters.remove(nf);
+		}
+		
+		return ret;
 	}
 	
 	protected String getQualifiedProperty(String property){