diff options
author | 2025-03-05 17:28:07 +0000 | |
---|---|---|
committer | 2025-03-11 09:33:56 +0000 | |
commit | b701e3090b90b4bb3aef93c9f89a6d642e6e084a (patch) | |
tree | 46c3ba9a98d6e7a45832b2514b837545190321af /cps-ri/src/main | |
parent | 025b21992b7b88d03f630beb8299bf2be28286a9 (diff) |
Allow limiting results in queryDataLeaf
This exposes queryResultLimit parameter in queryDataLeaf,
same as was implemented for queryDataNodes API.
Issue-ID: CPS-2680
Signed-off-by: danielhanrahan <daniel.hanrahan@est.tech>
Change-Id: Ieb922ac1acc91dbfd67fb5ade7856213a2f93ce8
Diffstat (limited to 'cps-ri/src/main')
-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); |