uros-b commented on code in PR #56598:
URL: https://github.com/apache/spark/pull/56598#discussion_r3444054727
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDB.scala:
##########
@@ -1593,7 +1605,63 @@ class RocksDB(
}
writer.deleteRange(beginKeyWithPrefix, endKeyForChangelog)
}
- // TODO: Add metrics update for deleteRange operations
+ }
+
+ /** Count the keys currently present in `[beginKeyWithPrefix,
+ * endKeyWithPrefix)`, split into non-internal vs internal column-family
+ * buckets.
+ *
+ * @param beginKeyWithPrefix
+ * Already-prefixed start key (inclusive)
+ * @param endKeyWithPrefix
+ * Already-prefixed end key (exclusive); used as the iterator upper bound
+ * so we never touch keys beyond it.
+ * @param cfName
+ * Caller-supplied column family. Used when `includesPrefix` is false;
Review Comment:
```suggestion
* Caller-supplied column family. Used when `includesPrefix` is false.
```
--
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]
