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 94d26b5764ca..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. @@ -54,13 +55,14 @@ public static void main(String[] args) { .apply( MapElements.via( new SimpleFunction() { - @Override - public String apply(String input) - { - return input.toUpperCase(); - } - })) - .apply(ParDo.of(new DoFn() { + @Override + public String apply(String input) { + return input.toUpperCase(); + } + })) + .apply( + ParDo.of( + new DoFn() { @ProcessElement public void processElement(@Element String element) { LOG.info(element);