We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a47f495 commit 47d7a29Copy full SHA for 47d7a29
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingSymmetricHashJoinExec.scala
@@ -465,16 +465,6 @@ case class StreamingSymmetricHashJoinExec(
465
}
466
467
468
-
469
- /**
470
- * Get an iterator over the values stored in this joiner's state manager for the given key.
471
- *
472
- * Should not be interleaved with mutations.
473
- */
474
-// def get(key: UnsafeRow): Iterator[UnsafeRow] = {
475
-// joinStateManager.get(key)
476
-// }
477
478
/**
479
* Builds an iterator over old state key-value pairs, removing them lazily as they're produced.
480
*
0 commit comments