Skip to content

Commit 78b770b

Browse files
Address review: use @element instead of ProcessContext
1 parent c632f80 commit 78b770b

1 file changed

Lines changed: 11 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: 11 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -51,16 +51,19 @@ 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>() {
55-
@Override
56-
public String apply(String input) {
57-
return input.toUpperCase();
58-
}
59-
}))
54+
.apply(
55+
MapElements.via(
56+
new SimpleFunction<String, String>() {
57+
@Override
58+
public String apply(String input)
59+
{
60+
return input.toUpperCase();
61+
}
62+
}))
6063
.apply(ParDo.of(new DoFn<String, Void>() {
6164
@ProcessElement
62-
public void processElement(ProcessContext c) {
63-
LOG.info(c.element());
65+
public void processElement(@Element String element) {
66+
LOG.info(element);
6467
}
6568
}));
6669

0 commit comments

Comments
 (0)