From 4adb82d47744082626f9d1f92e485bcb6afdcdce Mon Sep 17 00:00:00 2001 From: Vitaly Terentyev Date: Wed, 29 Apr 2026 20:48:14 +0400 Subject: [PATCH 1/2] Fix line ordering --- .../src/main/java/org/apache/beam/examples/ViewExample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java b/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java index d40d6cc333ef..e135742bb37b 100644 --- a/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java +++ b/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java @@ -39,7 +39,7 @@ // description: Demonstration of View transform usage. // multifile: false // default_example: false -// context_line: 49 +// context_line: 50 // categories: // - Core Transforms // complexity: MEDIUM From 33b37573635e98e705d32ff3e49acb97392b9b36 Mon Sep 17 00:00:00 2001 From: Vitaly Terentyev Date: Wed, 29 Apr 2026 21:18:37 +0400 Subject: [PATCH 2/2] Fix ViewExample --- .../src/main/java/org/apache/beam/examples/ViewExample.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java b/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java index e135742bb37b..c06618ff086a 100644 --- a/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java +++ b/examples/java/src/main/java/org/apache/beam/examples/ViewExample.java @@ -99,12 +99,12 @@ public void processElement( .withSideInput("citiesToCountries", citiesToCountriesView)); // [END main_section] - output.apply("Log", ParDo.of(new LogOutput<>("Output: "))); + output.apply("Log", ParDo.of(new LogOutput("Output: "))); pipeline.run(); } - static class LogOutput extends DoFn { + static class LogOutput extends DoFn, KV> { private static final Logger LOG = LoggerFactory.getLogger(LogOutput.class); private final String prefix;