nielm commented on code in PR #29601:
URL: https://github.com/apache/beam/pull/29601#discussion_r1416145435
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java:
##########
@@ -204,6 +229,29 @@
* .withTransaction(tx));
* }</pre>
*
+ * <h4>Bulk reading of multiple queries or tables</h4>
+ *
+ * You can perform multiple consistent reads on a set of tables or using a set
of queries by
+ * constructing a {@link ReadAll} transform using {@link SpannerIO#readAll()
SpannerIO.readAll()}.
+ * This transform takes a {@link PCollection} of {@link ReadOperation}
elements, and performs the
+ * partitioned read on each of them using the same Read Only Transaction for
consistent results.
+ *
+ * <p>Note that this transform should <strong>not</strong> be used in
Streaming pipelines. This is
+ * because the same Read Only Transaction, which is created on pipeline
startup will be used for all
Review Comment:
Created once, and yes at pipeline execution. Updated text.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
