aboutsummaryrefslogtreecommitdiff
path: root/sql/hive-thriftserver/src
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2016-04-22 17:43:56 -0700
committerReynold Xin <rxin@databricks.com>2016-04-22 17:43:56 -0700
commitd7d0cad0ad7667c0e09ae01601ee0e4d0b09963c (patch)
tree10ab6d65e25c6451a1cdde83321c989a6e901856 /sql/hive-thriftserver/src
parentc431a76d0628985bb445189b9a2913dd41b86f7b (diff)
downloadspark-d7d0cad0ad7667c0e09ae01601ee0e4d0b09963c.tar.gz
spark-d7d0cad0ad7667c0e09ae01601ee0e4d0b09963c.tar.bz2
spark-d7d0cad0ad7667c0e09ae01601ee0e4d0b09963c.zip
[SPARK-14855][SQL] Add "Exec" suffix to physical operators
## What changes were proposed in this pull request? This patch adds "Exec" suffix to all physical operators. Before this patch, Spark's physical operators and logical operators are named the same (e.g. Project could be logical.Project or execution.Project), which caused small issues in code review and bigger issues in code refactoring. ## How was this patch tested? N/A Author: Reynold Xin <rxin@databricks.com> Closes #12617 from rxin/exec-node.
Diffstat (limited to 'sql/hive-thriftserver/src')
-rw-r--r--sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala
index bc45334036..f15f5b01e2 100644
--- a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala
+++ b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala
@@ -224,7 +224,7 @@ class HiveThriftBinaryServerSuite extends HiveThriftJdbcTest {
val plan = statement.executeQuery("explain select * from test_table")
plan.next()
plan.next()
- assert(plan.getString(1).contains("InMemoryColumnarTableScan"))
+ assert(plan.getString(1).contains("InMemoryTableScan"))
val rs1 = statement.executeQuery("SELECT key FROM test_table ORDER BY KEY DESC")
val buf1 = new collection.mutable.ArrayBuffer[Int]()
@@ -310,7 +310,7 @@ class HiveThriftBinaryServerSuite extends HiveThriftJdbcTest {
val plan = statement.executeQuery("explain select key from test_map ORDER BY key DESC")
plan.next()
plan.next()
- assert(plan.getString(1).contains("InMemoryColumnarTableScan"))
+ assert(plan.getString(1).contains("InMemoryTableScan"))
val rs = statement.executeQuery("SELECT key FROM test_map ORDER BY KEY DESC")
val buf = new collection.mutable.ArrayBuffer[Int]()