szehon-ho commented on code in PR #56283:
URL: https://github.com/apache/spark/pull/56283#discussion_r3376639622
##########
sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/autocdc/Scd2BatchProcessor.scala:
##########
@@ -299,9 +496,27 @@ object Scd2BatchProcessor {
)
/**
- * Schema of the CDC metadata struct column for SCD2 target table rows.
+ * Name of temporary column projected onto microbatch to compute the min
sequencing value per
+ * key within the microbatch.
+ */
+ private[autocdc] val minSequenceColName: String =
s"${AutoCdcReservedNames.prefix}min_sequence"
+
+ /**
+ * Name of temporary column projected used to identify the sequence
associated with the anchor
Review Comment:
nit: "projected used" reads awkwardly.
```suggestion
* Name of the temporary column used to identify the sequence associated
with the anchor
```
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
