From 86f378df7db00b006e2809f40bd3fda17fcfcf30 Mon Sep 17 00:00:00 2001 From: Muntazir Fadhel Date: Thu, 1 Oct 2026 01:01:08 +0300 Subject: [PATCH] Use SimpleReduceFunction in the DSL job tutorials --- docs/docs/develop/writing-jobs/twitter.md | 2 +- docs/docs/develop/writing-jobs/word-count.md | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/docs/develop/writing-jobs/twitter.md b/docs/docs/develop/writing-jobs/twitter.md index 963c09d57..1f950015e 100644 --- a/docs/docs/develop/writing-jobs/twitter.md +++ b/docs/docs/develop/writing-jobs/twitter.md @@ -151,7 +151,7 @@ The operators thereafter are nearly equivalent to the previous tutorial. We need .keyBy(WordCountPair::getWord) // On a hopping window of 10 seconds .window(WindowSpec.timed(Duration.ofSeconds(10))) - .reduce((ReduceFunctionImpl) (acc, item) -> { + .reduce((SimpleReduceFunction) (acc, item) -> { if (acc.getWord() != null && !acc.getWord().isEmpty() && !acc.getWord().equals(item.getWord())) { log.warn("keys dont match: acc ({}) vs item ({})", acc.getWord(), item.getWord()); } diff --git a/docs/docs/develop/writing-jobs/word-count.md b/docs/docs/develop/writing-jobs/word-count.md index ac00652a4..4427e542d 100644 --- a/docs/docs/develop/writing-jobs/word-count.md +++ b/docs/docs/develop/writing-jobs/word-count.md @@ -39,7 +39,7 @@ public class WordCountDslJob extends MantisJobProvider { }) .keyBy(WordCountPair::getWord) .window(WindowSpec.timed(Duration.ofSeconds(10))) - .reduce((ReduceFunctionImpl) (acc, item) -> { + .reduce((SimpleReduceFunction) (acc, item) -> { if (acc.getWord() != null && !acc.getWord().isEmpty() && !acc.getWord().equals(item.getWord())) { log.warn("keys dont match: acc ({}) vs item ({})", acc.getWord(), item.getWord()); }