(beam) branch master updated: Modernize legacy DoFn in BatchElementsExample (#40557) (#40560)

[chamikara]

This is an automated email from the ASF dual-hosted git repository.

chamikaramj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new b4ecb26ada0 Modernize legacy DoFn in BatchElementsExample (#40557) 
(#40560)
b4ecb26ada0 is described below

commit b4ecb26ada0b8355c8a32ddb0799ae447339c8cf
Author: CH-Abhinav <chinnala.abhin...@gmail.com>
AuthorDate: Tue Oct 20 01:40:49 2026 +0530

    Modernize legacy DoFn in BatchElementsExample (#40557) (#40560)
---
 .../main/java/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 79130d7ac13..42cfd4f071d 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 @@ public class BatchElementsExample {
     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);
       }
     }
   }