scala style

apache · Mar 26, 2024 · 83e5721 · 83e5721
1 parent b34b66c
commit 83e5721
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...src/main/scala/org/apache/spark/sql/execution/streaming/StatefulProcessorHandleImpl.scala b/...src/main/scala/org/apache/spark/sql/execution/streaming/StatefulProcessorHandleImpl.scala
@@ -164,7 +164,7 @@ class StatefulProcessorHandleImpl(
 
   /**
    * Function to retrieve all registered timers for all grouping keys
-   * @param expiryTimestampMs - threshold for expired timestamp in milliseconds, this function
+   * @param expiryTimestampMs Threshold for expired timestamp in milliseconds, this function
    *                          will return every timers that has (strictly) smaller timestamp
    * @return - iterator of registered timers for all grouping keys
    */

diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TimerStateImpl.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TimerStateImpl.scala
@@ -187,8 +187,8 @@ class TimerStateImpl(
 
   /**
    * Function to get all the registered timers for all grouping keys
-   * @param expiryTimestampMs - threshold for expired timestamp in milliseconds, this function
-   *                          will return every timers that is before this threshold
+   * @param expiryTimestampMs Threshold for expired timestamp in milliseconds, this function
+   *                          will return every timers that has (strictly) smaller timestamp
    * @return - iterator of all the registered timers for all grouping keys
    */
   def getExpiredTimers(expiryTimestampMs: Long): Iterator[(Any, Long)] = {