-
- Downloads
[SPARK-22153][SQL] Rename ShuffleExchange -> ShuffleExchangeExec
## What changes were proposed in this pull request? For some reason when we added the Exec suffix to all physical operators, we missed this one. I was looking for this physical operator today and couldn't find it, because I was looking for ExchangeExec. ## How was this patch tested? This is a simple rename and should be covered by existing tests. Author: Reynold Xin <rxin@databricks.com> Closes #19376 from rxin/SPARK-22153.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 3 additions, 3 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/EnsureRequirements.scala 13 additions, 13 deletions...che/spark/sql/execution/exchange/EnsureRequirements.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala 19 additions, 19 deletions...he/spark/sql/execution/exchange/ExchangeCoordinator.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchangeExec.scala 5 additions, 5 deletions...he/spark/sql/execution/exchange/ShuffleExchangeExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala 3 additions, 3 deletions...src/main/scala/org/apache/spark/sql/execution/limit.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala 2 additions, 2 deletions.../spark/sql/execution/streaming/IncrementalExecution.scala
- sql/core/src/test/scala/org/apache/spark/sql/CachedTableSuite.scala 3 additions, 2 deletions...rc/test/scala/org/apache/spark/sql/CachedTableSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala 5 additions, 5 deletions.../src/test/scala/org/apache/spark/sql/DataFrameSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala 2 additions, 2 deletions...re/src/test/scala/org/apache/spark/sql/DatasetSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/ExchangeCoordinatorSuite.scala 11 additions, 11 deletions...apache/spark/sql/execution/ExchangeCoordinatorSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/ExchangeSuite.scala 6 additions, 6 deletions.../scala/org/apache/spark/sql/execution/ExchangeSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala 16 additions, 16 deletions...t/scala/org/apache/spark/sql/execution/PlannerSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/sources/BucketedReadSuite.scala 5 additions, 5 deletions...cala/org/apache/spark/sql/sources/BucketedReadSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/streaming/EnsureStatefulOpPartitioningSuite.scala 2 additions, 2 deletions...ark/sql/streaming/EnsureStatefulOpPartitioningSuite.scala
Loading
Please register or sign in to comment