fix: Adapt write() example of KinesisIO to AWS SDK V2 interface (#37122)

yuwtennis · web-flow · commit 471ebc4f239d · 2025-12-16T20:15:38.000-05:00
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
@@ -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>
  *

Original file line number	Diff line number	Diff line change
`@@ -237,9 +237,9 @@`
`237`	`237`	`*`
`238`	`238`	`* <pre>{@code PCollection<KV<String, byte[]>> data = ...;`
`239`	`239`	`*`
`240`		`- * data.apply(KinesisIO.write()`
	`240`	`+ * data.apply(KinesisIO.<KV<String, byte[]>>write()`
`241`	`241`	`* .withStreamName("streamName")`
`242`		`- * .withPartitionKey(KV::getKey)`
	`242`	`+ * .withPartitioner(KV::getKey)`
`243`	`243`	`* .withSerializer(KV::getValue);`
`244`	`244`	`* }</pre>`
`245`	`245`	`*`