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..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
@@ -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
@@ -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<T> extends DoFn<T, T> {
+  static class LogOutput extends DoFn<KV<String, String>, KV<String, String>> {
     private static final Logger LOG = LoggerFactory.getLogger(LogOutput.class);
     private final String prefix;