dedocibula commented on code in PR #35408:
URL: https://github.com/apache/beam/pull/35408#discussion_r2165239650
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/ChangeStreamResultSet.java:
##########
@@ -108,6 +109,48 @@ public Struct getCurrentRowAsStruct() {
return resultSet.getCurrentRowAsStruct();
}
+ /**
+ * Returns the change stream record proto at the current pointer of the
result set. It also
+ * updates the timestamp at which the record was read. This function
enhances the getProtoMessage
+ * function but only focus on the ChangeStreamRecord type.
+ *
+ * @param columnIndex Index of the column.
+ * @return a change stream record as a proto or null
+ */
+ public com.google.spanner.v1.ChangeStreamRecord
getProtoChangeStreamRecord(int columnIndex) {
Review Comment:
Do we really need the index column here?
--
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]
