diff options
author | Reynold Xin <rxin@databricks.com> | 2016-04-22 17:43:56 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-04-22 17:43:56 -0700 |
commit | d7d0cad0ad7667c0e09ae01601ee0e4d0b09963c (patch) | |
tree | 10ab6d65e25c6451a1cdde83321c989a6e901856 /sql/hive-thriftserver/src | |
parent | c431a76d0628985bb445189b9a2913dd41b86f7b (diff) | |
download | spark-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.scala | 4 |
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]() |