Add a new method getNextPossibleValuesWithMap

(calculate top with map)

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

pom.xml

@@ -9,7 +9,7 @@
 
 	<groupId>org.gcube.accounting</groupId>
 	<artifactId>accounting-analytics</artifactId>
-	<version>2.3.0-SNAPSHOT</version>
+	<version>2.4.0-SNAPSHOT</version>
 	<name>accounting-analytics</name>
 	
 	<properties>
@@ -26,9 +26,10 @@
 
 	<dependencyManagement>
 		<dependencies>
+
 			<dependency>
 				<groupId>org.gcube.distribution</groupId>
-				<artifactId>maven-smartgears-bom</artifactId>
+				<artifactId>gcube-bom</artifactId>
 				<version>LATEST</version>
 				<type>pom</type>
 				<scope>import</scope>

src/main/java/org/gcube/accounting/analytics/TemporalConstraint.java

@@ -31,6 +31,7 @@ public class TemporalConstraint {
 	 */
 	public enum AggregationMode {
 		YEARLY, MONTHLY, DAILY, HOURLY, MINUTELY, SECONDLY, MILLISECONDLY  
+		
 	}
 	
 	/**
@@ -39,6 +40,7 @@ public class TemporalConstraint {
 	 * @author Luca Frosini (ISTI - CNR)
 	 */
 	public enum CalendarEnum {
+		
 		YEAR(Calendar.YEAR),
 		MONTH(Calendar.MONTH),
 		DAY(Calendar.DAY_OF_MONTH),

src/main/java/org/gcube/accounting/analytics/UsageValue.java

@@ -9,15 +9,16 @@ import org.gcube.accounting.datamodel.AggregatedUsageRecord;
  *
  */
 public abstract class UsageValue {
+	
+	public UsageValue(){}
+	
 	protected Class<? extends AggregatedUsageRecord<?, ?>> clz;
-	protected TemporalConstraint temporalConstraint;		
-	//protected List<FiltersValue> filtersValue;
+	protected TemporalConstraint temporalConstraint;			
 	protected String identifier;
 	protected Double d;
 	protected String orderingProperty;
 	protected String context;
 	
-	public UsageValue(){}
 	public abstract Class<? extends AggregatedUsageRecord<?, ?>> getClz();
 	public abstract String getIdentifier();
 	public abstract Double getD();

src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceBackendQuery.java

@@ -115,6 +115,23 @@ public interface AccountingPersistenceBackendQuery {
 					String key, String orderingProperty) throws 
 					DuplicatedKeyFilterException, KeyException, ValueException, 
 					Exception;
+	
+	
+
+	/**
+	 * Same method but use if possible a map-reduce
+	 * @param clz
+	 * @param temporalConstraint
+	 * @param filters
+	 * @param key
+	 * @param orderingProperty
+	 * @return
+	 * @throws Exception
+	 */
+	public SortedSet<NumberedFilter> getNextPossibleValuesWithMap(
+			Class<? extends AggregatedRecord<?, ?>> clz,
+			TemporalConstraint temporalConstraint, List<Filter> filters,
+			String key, String orderingProperty) throws Exception;
 
 	/**
 	 * Close the connection to persistence
@@ -252,4 +269,6 @@ public interface AccountingPersistenceBackendQuery {
 			TemporalConstraint temporalConstraint, List<Filter> filters,List<String> contexts)
 			throws Exception;
 
+	
+
 }

src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceQuery.java

@@ -247,6 +247,17 @@ public class AccountingPersistenceQuery implements AccountingPersistenceBackendQ
 
 	}
 
+	
+	@Override
+	public SortedSet<NumberedFilter> getNextPossibleValuesWithMap(
+			Class<? extends AggregatedRecord<?, ?>> clz,
+			TemporalConstraint temporalConstraint, List<Filter> filters,
+			String key, String orderingProperty) throws Exception {
+		return AccountingPersistenceBackendQueryFactory.getInstance()
+				.getNextPossibleValuesWithMap(clz, temporalConstraint, filters, 
+						key, orderingProperty);
+	}
+	
 	/**
 	 * {@inheritDoc}
 	 */
@@ -337,6 +348,8 @@ public class AccountingPersistenceQuery implements AccountingPersistenceBackendQ
 		}
 		return got;
 	}
+	
+