Skip to content

Commit 88ebf83

Browse files
Fix serial warning in starter and example archetype
1 parent 18395a2 commit 88ebf83

1 file changed

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

5353
p.apply(Create.of("Hello", "World"))
54-
.apply(MapElements.via(new SimpleFunction<String, String>() {
54+
.apply(MapElements.via(
55+
new @SuppressWarnings("serial")
56+
SimpleFunction<String, String>() {
5557
@Override
5658
public String apply(String input) {
5759
return input.toUpperCase();
5860
}
5961
}))
60-
.apply(ParDo.of(new DoFn<String, Void>() {
62+
.apply(ParDo.of(
63+
new @SuppressWarnings("serial")
64+
DoFn<String, Void>() {
6165
@ProcessElement
62-
public void processElement(ProcessContext c) {
66+
public void
67+
processElement(ProcessContext c) {
6368
LOG.info(c.element());
6469
}
6570
}));

0 commit comments

Comments
 (0)