aboutsummaryrefslogtreecommitdiffstats
path: root/cps-ri
diff options
context:
space:
mode:
Diffstat (limited to 'cps-ri')
-rw-r--r--cps-ri/src/main/java/org/onap/cps/ri/CpsDataPersistenceServiceImpl.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/cps-ri/src/main/java/org/onap/cps/ri/CpsDataPersistenceServiceImpl.java b/cps-ri/src/main/java/org/onap/cps/ri/CpsDataPersistenceServiceImpl.java
index e102765a64..a510d308d6 100644
--- a/cps-ri/src/main/java/org/onap/cps/ri/CpsDataPersistenceServiceImpl.java
+++ b/cps-ri/src/main/java/org/onap/cps/ri/CpsDataPersistenceServiceImpl.java
@@ -242,7 +242,7 @@ public class CpsDataPersistenceServiceImpl implements CpsDataPersistenceService
@Override
public <T> Set<T> queryDataLeaf(final String dataspaceName, final String anchorName, final String cpsPath,
- final Class<T> targetClass) {
+ final int queryResultLimit, final Class<T> targetClass) {
final CpsPathQuery cpsPathQuery = getCpsPathQuery(cpsPath);
if (!cpsPathQuery.hasAttributeAxis()) {
throw new IllegalArgumentException(
@@ -251,7 +251,7 @@ public class CpsDataPersistenceServiceImpl implements CpsDataPersistenceService
final String attributeName = cpsPathQuery.getAttributeAxisAttributeName();
final List<DataNode> dataNodes = queryDataNodes(dataspaceName, anchorName, cpsPath,
- FetchDescendantsOption.OMIT_DESCENDANTS);
+ FetchDescendantsOption.OMIT_DESCENDANTS, queryResultLimit);
return dataNodes.stream()
.map(dataNode -> {
final Object attributeValue = dataNode.getLeaves().get(attributeName);