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<WordCountPair>) (acc, item) -> {
+        .reduce((SimpleReduceFunction<WordCountPair>) (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<String> {
             })
             .keyBy(WordCountPair::getWord)
             .window(WindowSpec.timed(Duration.ofSeconds(10)))
-            .reduce((ReduceFunctionImpl<WordCountPair>) (acc, item) -> {
+            .reduce((SimpleReduceFunction<WordCountPair>) (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());
                 }