diff --git a/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceBackendQuery.java b/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceBackendQuery.java index 99c19f8..04422be 100644 --- a/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceBackendQuery.java +++ b/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceBackendQuery.java @@ -30,7 +30,7 @@ public abstract class AccountingPersistenceBackendQuery { * #Info is the value. The result is relative to an Usage Record Type, * respect a TemporalConstraint and can be applied one or more filters. * - * @param aggregatedRecordClass + * @param clz * the Record Class of interest * @param temporalConstraint * the TemporalConstraint (interval and aggregation) @@ -47,7 +47,7 @@ public abstract class AccountingPersistenceBackendQuery { * if fails */ public abstract SortedMap getTimeSeries( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters) throws Exception; @@ -58,7 +58,7 @@ public abstract class AccountingPersistenceBackendQuery { * an Exception is thrown. The values are ordered from the most occurred * value. * - * @param aggregatedRecordClass + * @param clz * the Usage Record Class of interest * @param temporalConstraint * the TemporalConstraint (interval and aggregation) @@ -77,17 +77,17 @@ public abstract class AccountingPersistenceBackendQuery { * if fails */ public SortedMap> getTopValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters) throws Exception { String orderingProperty = AccountingPersistenceQuery - .getDefaultOrderingProperties(aggregatedRecordClass); - return getTopValues(aggregatedRecordClass, temporalConstraint, filters, + .getDefaultOrderingProperties(clz); + return getTopValues(clz, temporalConstraint, filters, orderingProperty); } public abstract SortedMap> getTopValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters, String orderingProperty) throws Exception; @@ -98,7 +98,7 @@ public abstract class AccountingPersistenceBackendQuery { * allowed otherwise an Exception is thrown. The values are ordered from the * most occurred value. * - * @param aggregatedRecordClass + * @param clz * the Usage Record Class of interest * @param temporalConstraint * the TemporalConstraint (interval and aggregation) @@ -117,17 +117,17 @@ public abstract class AccountingPersistenceBackendQuery { * if fails */ public SortedSet getNextPossibleValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters) throws Exception { String orderingProperty = AccountingPersistenceQuery - .getDefaultOrderingProperties(aggregatedRecordClass); - return getNextPossibleValues(aggregatedRecordClass, temporalConstraint, + .getDefaultOrderingProperties(clz); + return getNextPossibleValues(clz, temporalConstraint, filters, orderingProperty); } public abstract SortedSet getNextPossibleValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters, String orderingProperty) throws Exception; diff --git a/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceQuery.java b/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceQuery.java index a392874..ce388a8 100644 --- a/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceQuery.java +++ b/src/main/java/org/gcube/accounting/analytics/persistence/AccountingPersistenceQuery.java @@ -61,14 +61,14 @@ public class AccountingPersistenceQuery { } public static SortedSet getQuerableKeys( - Class> aggregatedRecordClass) + Class> clz) throws Exception { - AggregatedRecord instance = aggregatedRecordClass.newInstance(); + AggregatedRecord instance = clz.newInstance(); return getQuerableKeys(instance); } - public static String getDefaultOrderingProperties(Class> recordClass){ - if(recordClass.isAssignableFrom(AggregatedStorageUsageRecord.class)){ + public static String getDefaultOrderingProperties(Class> clz){ + if(clz.isAssignableFrom(AggregatedStorageUsageRecord.class)){ return AggregatedStorageUsageRecord.DATA_VOLUME; } return AggregatedRecord.OPERATION_COUNT; @@ -119,12 +119,12 @@ public class AccountingPersistenceQuery { } public SortedMap getTimeSeries( - Class> aggregatedRecordClass, - TemporalConstraint temporalConstraint, List filters, boolean pad) - throws Exception { + Class> clz, + TemporalConstraint temporalConstraint, List filters, + boolean pad) throws Exception { SortedMap ret = AccountingPersistenceBackendQueryFactory.getInstance() - .getTimeSeries(aggregatedRecordClass, temporalConstraint, + .getTimeSeries(clz, temporalConstraint, filters); if(pad){ @@ -135,18 +135,18 @@ public class AccountingPersistenceQuery { } public SortedMap> getTopValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters, String orderingProperty, boolean pad, int limit) throws Exception { SortedMap> ret; if(orderingProperty==null){ - orderingProperty = getDefaultOrderingProperties(aggregatedRecordClass); + orderingProperty = getDefaultOrderingProperties(clz); } ret = AccountingPersistenceBackendQueryFactory.getInstance() - .getTopValues(aggregatedRecordClass, temporalConstraint, + .getTopValues(clz, temporalConstraint, filters, orderingProperty); @@ -163,20 +163,20 @@ public class AccountingPersistenceQuery { } public SortedMap> getTopValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters) throws Exception { return AccountingPersistenceBackendQueryFactory.getInstance() - .getTopValues(aggregatedRecordClass, temporalConstraint, + .getTopValues(clz, temporalConstraint, filters); } public SortedSet getNextPossibleValues( - Class> aggregatedRecordClass, + Class> clz, TemporalConstraint temporalConstraint, List filters) throws Exception { return AccountingPersistenceBackendQueryFactory.getInstance() - .getNextPossibleValues(aggregatedRecordClass, + .getNextPossibleValues(clz, temporalConstraint, filters); }