diff options
| author | Reynold Xin <rxin@databricks.com> | 2015-11-24 12:54:37 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-11-24 12:54:37 -0800 |
| commit | f3152722791b163fa66597b3684009058195ba33 (patch) | |
| tree | c3b23ead8eaea14229f5b21642d2a4e8c5c191b2 /core | |
| parent | 81012546ee5a80d2576740af0dad067b0f5962c5 (diff) | |
| download | spark-f3152722791b163fa66597b3684009058195ba33.tar.gz spark-f3152722791b163fa66597b3684009058195ba33.tar.bz2 spark-f3152722791b163fa66597b3684009058195ba33.zip | |
[SPARK-11946][SQL] Audit pivot API for 1.6.
Currently pivot's signature looks like
```scala
scala.annotation.varargs
def pivot(pivotColumn: Column, values: Column*): GroupedData
scala.annotation.varargs
def pivot(pivotColumn: String, values: Any*): GroupedData
```
I think we can remove the one that takes "Column" types, since callers should always be passing in literals. It'd also be more clear if the values are not varargs, but rather Seq or java.util.List.
I also made similar changes for Python.
Author: Reynold Xin <rxin@databricks.com>
Closes #9929 from rxin/SPARK-11946.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index ae725b467d..77a184dfe4 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -1574,7 +1574,6 @@ class DAGScheduler( } def stop() { - logInfo("Stopping DAGScheduler") messageScheduler.shutdownNow() eventProcessLoop.stop() taskScheduler.stop() |