From 8d232867c617c3853e5cd32bd45732c6fba5009e Mon Sep 17 00:00:00 2001
From: ywatanabe <yu.w.tennis@gmail.com>
Date: Tue, 16 Dec 2025 15:30:38 +0900
Subject: [PATCH] fix: Adapt write() example of KinesisIO to AWS SDK V2
 interface

---
 .../java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java
index 835bde170d33..2de4a47ebaec 100644
--- a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java
+++ b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java
@@ -237,9 +237,9 @@
  *
  * <pre>{@code PCollection<KV<String, byte[]>> data = ...;
  *
- * data.apply(KinesisIO.write()
+ * data.apply(KinesisIO.<KV<String, byte[]>>write()
  *     .withStreamName("streamName")
- *     .withPartitionKey(KV::getKey)
+ *     .withPartitioner(KV::getKey)
  *     .withSerializer(KV::getValue);
  * }</pre>
  *