From 61570273ab08f5f6096b3f3e81581715b2d3e5d4 Mon Sep 17 00:00:00 2001
From: Abhinav <abgamein306@gmail.com>
Date: Tue, 13 Oct 2026 23:22:46 +0530
Subject: [PATCH] Modernize legacy DoFn in BatchElementsExample (#40557)

---
 .../org/apache/beam/examples/BatchElementsExample.java     | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/examples/java/src/main/java/org/apache/beam/examples/BatchElementsExample.java b/examples/java/src/main/java/org/apache/beam/examples/BatchElementsExample.java
index 79130d7ac138..42cfd4f071d0 100644
--- a/examples/java/src/main/java/org/apache/beam/examples/BatchElementsExample.java
+++ b/examples/java/src/main/java/org/apache/beam/examples/BatchElementsExample.java
@@ -68,13 +68,10 @@ static class LogOutput extends DoFn<List<String>, String> {
     private static final Logger LOG = LoggerFactory.getLogger(LogOutput.class);
 
     @ProcessElement
-    public void processElement(ProcessContext c) throws Exception {
-      List<String> batch = c.element();
-
+    public void processElement(@Element List<String> batch, OutputReceiver<String> receiver) {
       LOG.info("Batch Contents: {}", batch);
-
       for (String element : batch) {
-        c.output(element);
+        receiver.output(element);
       }
     }
   }