Skip to content

Commit 1c011ab

Browse files
committed
Update the code comment
1 parent e2201ef commit 1c011ab

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -457,8 +457,8 @@ class SymmetricHashJoinStateManager(
457457
/**
458458
* Convert the value row to (actual value, match) pair.
459459
*
460-
* NOTE: implementations should ensure the result row is NOT reused during execution, as
461-
* caller may use the value to store without copy().
460+
* NOTE: implementations should ensure the result row is NOT reused during execution, so
461+
* that caller can safely read the value in any time.
462462
*/
463463
def convertValue(value: UnsafeRow): ValueAndMatchPair
464464

0 commit comments

Comments
 (0)