From f0b2c8d61f0a872680c19f4a9b91960baf4cd886 Mon Sep 17 00:00:00 2001 From: Luca Frosini Date: Thu, 25 Nov 2021 12:27:52 +0100 Subject: [PATCH] fixed limit issue on top values --- .../postgresql/AccountingPersistenceQueryPostgreSQL.java | 4 ++-- .../postgresql/AccountingPersistenceQueryPostgreSQLTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQL.java b/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQL.java index fbea795..6ef5b7d 100644 --- a/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQL.java +++ b/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQL.java @@ -264,12 +264,12 @@ public class AccountingPersistenceQueryPostgreSQL implements AccountingPersisten } @Override - public SortedMap> getTopValues(String topKey, String orderingProperty) + public SortedMap> getTopValues(String topKey, String orderingProperty, Integer limit) throws Exception { SortedMap> ret = new TreeMap<>(); - SortedSet top = getNumberedValues(topKey, orderingProperty, 10); + SortedSet top = getNumberedValues(topKey, orderingProperty, limit); for(NumberedFilter numberedFilter : top) { filters.add(numberedFilter); diff --git a/src/test/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQLTest.java b/src/test/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQLTest.java index b758b00..75bc849 100644 --- a/src/test/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQLTest.java +++ b/src/test/java/org/gcube/accounting/analytics/persistence/postgresql/AccountingPersistenceQueryPostgreSQLTest.java @@ -249,7 +249,7 @@ public class AccountingPersistenceQueryPostgreSQLTest extends ContextTest { accountingPersistenceQueryPostgreSQL.setTemporalConstraint(temporalConstraint); accountingPersistenceQueryPostgreSQL.setFilters(filters); - SortedMap> topTimeSeries = accountingPersistenceQueryPostgreSQL.getTopValues(AggregatedServiceUsageRecord.CALLED_METHOD, orderingProperty); + SortedMap> topTimeSeries = accountingPersistenceQueryPostgreSQL.getTopValues(AggregatedServiceUsageRecord.CALLED_METHOD, orderingProperty, null); for(NumberedFilter numberedFilter : topTimeSeries.keySet()) { logger.debug("{}", numberedFilter); SortedMap timeseries = topTimeSeries.get(numberedFilter);