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);
       }
     }
   }