eason-yuchen-liu commented on code in PR #47188:
URL: https://github.com/apache/spark/pull/47188#discussion_r1669452848
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreChangelog.scala:
##########
@@ -55,6 +56,15 @@ object RecordType extends Enumeration {
}
}
+ def getRecordTypeAsString(recordType: RecordType): String = {
+ recordType match {
+ case PUT_RECORD => "update"
Review Comment:
Merge is only used in changlog v2. Since this PR only aims for v1, the
support of merge should be done later.
--
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: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
