diff options
| author | Wenchen Fan <wenchen@databricks.com> | 2015-10-14 15:08:13 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-10-14 15:08:13 -0700 |
| commit | 9a430a027faafb083ca569698effb697af26a1db (patch) | |
| tree | 2996be5e0958cc16d7559749ddaf0dacf6af0206 /sql/core | |
| parent | cf2e0ae7205443f052463e8cb9334ae2b6df2d0e (diff) | |
| download | spark-9a430a027faafb083ca569698effb697af26a1db.tar.gz spark-9a430a027faafb083ca569698effb697af26a1db.tar.bz2 spark-9a430a027faafb083ca569698effb697af26a1db.zip | |
[SPARK-11068] [SQL] [FOLLOW-UP] move execution listener to util
Author: Wenchen Fan <wenchen@databricks.com>
Closes #9119 from cloud-fan/callback.
Diffstat (limited to 'sql/core')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala | 1 | ||||
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/util/QueryExecutionListener.scala (renamed from sql/core/src/main/scala/org/apache/spark/sql/QueryExecutionListener.scala) | 2 | ||||
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/util/DataFrameCallbackSuite.scala (renamed from sql/core/src/test/scala/org/apache/spark/sql/DataFrameCallbackSuite.scala) | 3 |
3 files changed, 4 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala b/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala index a835408f8a..3d5e35ab31 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala @@ -45,6 +45,7 @@ import org.apache.spark.sql.execution.ui.{SQLListener, SQLTab} import org.apache.spark.sql.sources.BaseRelation import org.apache.spark.sql.types._ import org.apache.spark.sql.{execution => sparkexecution} +import org.apache.spark.sql.util.ExecutionListenerManager import org.apache.spark.util.Utils /** diff --git a/sql/core/src/main/scala/org/apache/spark/sql/QueryExecutionListener.scala b/sql/core/src/main/scala/org/apache/spark/sql/util/QueryExecutionListener.scala index 14fbebb45f..909a8abd22 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/QueryExecutionListener.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/util/QueryExecutionListener.scala @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.spark.sql +package org.apache.spark.sql.util import java.util.concurrent.locks.ReentrantReadWriteLock import scala.collection.mutable.ListBuffer diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameCallbackSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/util/DataFrameCallbackSuite.scala index 4e286a0076..eb056cd519 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameCallbackSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/util/DataFrameCallbackSuite.scala @@ -15,9 +15,10 @@ * limitations under the License. */ -package org.apache.spark.sql +package org.apache.spark.sql.util import org.apache.spark.SparkException +import org.apache.spark.sql.{functions, QueryTest} import org.apache.spark.sql.catalyst.plans.logical.{Aggregate, Project} import org.apache.spark.sql.execution.QueryExecution import org.apache.spark.sql.test.SharedSQLContext |