From 2885acfb5d974b840f832b185fa9674e72159da1 Mon Sep 17 00:00:00 2001
From: twosom <two_somang@icloud.com>
Date: Sun, 20 Oct 2024 23:07:27 +0900
Subject: [PATCH] update javadoc

---
 .../mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java b/sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java
index 0104db2a6078..69d9e19c5706 100644
--- a/sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java
+++ b/sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java
@@ -95,7 +95,7 @@
  * following example:
  *
  * <pre>{@code
- * pipeline.apply(
+ * PCollection<MqttRecord> records = pipeline.apply(
  *   MqttIO.readWithMetadata()
  *    .withConnectionConfiguration(MqttIO.ConnectionConfiguration.create(
  *      "tcp://host:11883",