This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 471ebc4f239 fix: Adapt write() example of KinesisIO to AWS SDK V2
interface (#37122)
471ebc4f239 is described below
commit 471ebc4f239d2577eec9f4b38a572320b07008bf
Author: Yu Watanabe <[email protected]>
AuthorDate: Wed Dec 17 10:15:38 2025 +0900
fix: Adapt write() example of KinesisIO to AWS SDK V2 interface (#37122)
---
.../src/main/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 835bde170d3..2de4a47ebae 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 @@ import
software.amazon.kinesis.common.InitialPositionInStream;
*
* <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>
*
