diff options
Diffstat (limited to 'cps-ri')
| -rw-r--r-- | cps-ri/src/main/java/org/onap/cps/ri/CpsDataPersistenceServiceImpl.java | 4 |
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); |