You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by js...@apache.org on 2023/05/12 15:55:45 UTC
[unomi] branch unomi-1.x updated: UNOMI-780 : Allow to use scroll query to get more than 10000 events (#621) (#622)
This is an automated email from the ASF dual-hosted git repository.
jsinovassinnaik pushed a commit to branch unomi-1.x
in repository https://gitbox.apache.org/repos/asf/unomi.git
The following commit(s) were added to refs/heads/unomi-1.x by this push:
new b44dc2e28 UNOMI-780 : Allow to use scroll query to get more than 10000 events (#621) (#622)
b44dc2e28 is described below
commit b44dc2e28795d1e1c26010eb553c7d8ab85f005a
Author: jsinovassin <58...@users.noreply.github.com>
AuthorDate: Fri May 12 16:55:41 2023 +0100
UNOMI-780 : Allow to use scroll query to get more than 10000 events (#621) (#622)
---
.../java/org/apache/unomi/services/impl/events/EventServiceImpl.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/services/src/main/java/org/apache/unomi/services/impl/events/EventServiceImpl.java b/services/src/main/java/org/apache/unomi/services/impl/events/EventServiceImpl.java
index 3465bfddc..8cd7bef13 100644
--- a/services/src/main/java/org/apache/unomi/services/impl/events/EventServiceImpl.java
+++ b/services/src/main/java/org/apache/unomi/services/impl/events/EventServiceImpl.java
@@ -260,11 +260,14 @@ public class EventServiceImpl implements EventService {
@Override
public PartialList<Event> search(Query query) {
+ if (query.getScrollIdentifier() != null) {
+ return persistenceService.continueScrollQuery(Event.class, query.getScrollIdentifier(), query.getScrollTimeValidity());
+ }
if (query.getCondition() != null && definitionsService.resolveConditionType(query.getCondition())) {
if (StringUtils.isNotBlank(query.getText())) {
return persistenceService.queryFullText(query.getText(), query.getCondition(), query.getSortby(), Event.class, query.getOffset(), query.getLimit());
} else {
- return persistenceService.query(query.getCondition(), query.getSortby(), Event.class, query.getOffset(), query.getLimit());
+ return persistenceService.query(query.getCondition(), query.getSortby(), Event.class, query.getOffset(), query.getLimit(), query.getScrollTimeValidity());
}
} else {
if (StringUtils.isNotBlank(query.getText())) {