diff --git a/sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java b/sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java
index d6afdecf11db..e9ee93fd3da6 100644
--- a/sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java
+++ b/sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java
@@ -26,6 +26,7 @@
 import org.apache.beam.sdk.transforms.SimpleFunction;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.apache.beam.sdk.transforms.DoFn.Element;
 
 /**
  * A starter example for writing Beam programs.
@@ -51,16 +52,20 @@ public static void main(String[] args) {
         PipelineOptionsFactory.fromArgs(args).withValidation().create());
 
     p.apply(Create.of("Hello", "World"))
-    .apply(MapElements.via(new SimpleFunction<String, String>() {
-      @Override
-      public String apply(String input) {
-        return input.toUpperCase();
-      }
-    }))
-    .apply(ParDo.of(new DoFn<String, Void>() {
+    .apply(
+      MapElements.via(
+        new SimpleFunction<String, String>() {
+         @Override
+         public String apply(String input) {
+             return input.toUpperCase();
+         }
+      }))
+    .apply(
+      ParDo.of(
+       new DoFn<String, Void>() {
       @ProcessElement
-      public void processElement(ProcessContext c)  {
-        LOG.info(c.element());
+      public void processElement(@Element String element)  {
+        LOG.info(element);
       }
     }));