Skip to content

Commit c632f80

Browse files
Remove unintended StarterPipeline changes from PicoWordCount PR
1 parent cf2eebe commit c632f80

1 file changed

Lines changed: 3 additions & 8 deletions

File tree

  • sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java

sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -51,20 +51,15 @@ public static void main(String[] args) {
5151
PipelineOptionsFactory.fromArgs(args).withValidation().create());
5252

5353
p.apply(Create.of("Hello", "World"))
54-
.apply(MapElements.via(
55-
new @SuppressWarnings("serial")
56-
SimpleFunction<String, String>() {
54+
.apply(MapElements.via(new SimpleFunction<String, String>() {
5755
@Override
5856
public String apply(String input) {
5957
return input.toUpperCase();
6058
}
6159
}))
62-
.apply(ParDo.of(
63-
new @SuppressWarnings("serial")
64-
DoFn<String, Void>() {
60+
.apply(ParDo.of(new DoFn<String, Void>() {
6561
@ProcessElement
66-
public void
67-
processElement(ProcessContext c) {
62+
public void processElement(ProcessContext c) {
6863
LOG.info(c.element());
6964
}
7065
}));

0 commit comments

Comments
 (0)