github/reitti
1
1
Fork 0
mirror of https://github.com/dedicatedcode/reitti.git synced 2026-01-09 17:37:57 -05:00
Code Issues 6 Packages Projects Releases Wiki Activity

bugfix: removed offset handling since this will skip unprocessed data… (#339)

Browse Source
This commit is contained in:
Daniel Graf
2025-10-08 13:06:59 +02:00
committed by GitHub
parent 56a98cb4fd
commit 9a05124eea
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/dedicatedcode/reitti/service/processing/ProcessingPipelineTrigger.java
View File

@@ -76,15 +76,14 @@ public class ProcessingPipelineTrigger {
}
private void handleDataForUser(User user, String previewId) {
int offset = 0;
int totalProcessed = 0;
while (true) {
List<RawLocationPoint> currentBatch;
if (previewId == null) {
currentBatch = rawLocationPointJdbcService.findByUserAndProcessedIsFalseOrderByTimestampWithLimit(user, BATCH_SIZE, offset);
currentBatch = rawLocationPointJdbcService.findByUserAndProcessedIsFalseOrderByTimestampWithLimit(user, BATCH_SIZE, 0);
} else {
currentBatch = previewRawLocationPointJdbcService.findByUserAndProcessedIsFalseOrderByTimestampWithLimit(user, previewId, BATCH_SIZE, offset);
currentBatch = previewRawLocationPointJdbcService.findByUserAndProcessedIsFalseOrderByTimestampWithLimit(user, previewId, BATCH_SIZE, 0);
}
if (currentBatch.isEmpty()) {
@@ -108,7 +107,6 @@ public class ProcessingPipelineTrigger {
new LocationProcessEvent(user.getUsername(), earliest, latest, previewId));
totalProcessed += currentBatch.size();
offset += BATCH_SIZE;
}
log.debug("Processed [{}] unprocessed points for user [{}]", totalProcessed, user.getId());