Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/19327#discussion_r140611178 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala --- @@ -329,6 +392,27 @@ class SymmetricHashJoinStateManager( } } + /** Get all the values for key and all indices, in a (value, index) tuple. */ + def getAllWithIndex(key: UnsafeRow, numValues: Long): Iterator[(UnsafeRow, Long)] = { --- End diff -- use `KeyWithIndexAndValue` for returning.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org