anishshri-db commented on code in PR #54373:
URL: https://github.com/apache/spark/pull/54373#discussion_r2830779227
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/runtime/MicroBatchExecution.scala:
##########
@@ -1414,6 +1438,32 @@ class MicroBatchExecution(
object MicroBatchExecution {
val BATCH_ID_KEY = "streaming.sql.batchId"
+
+ /**
+ * Computes the metadata path for a streaming source based on its
identifying name.
+ *
+ * @param sourceIdentifyingName The source's identifying name
+ * (UserProvided, FlowAssigned, or Unassigned)
+ * @param nextSourceId AtomicLong tracking the next positional source ID
+ * @param resolvedCheckpointRoot The resolved checkpoint root path
+ * @return The computed metadata path string
+ */
+ def getMetadataPath(
Review Comment:
can we move to `StreamingUtils` ?
--
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]
