aboutsummaryrefslogtreecommitdiff
path: root/sql/hive
diff options
context:
space:
mode:
authorDaoyuan Wang <daoyuan.wang@intel.com>2014-12-01 16:08:51 -0800
committerMichael Armbrust <michael@databricks.com>2014-12-01 16:08:51 -0800
commit4df60a8cbc58f2877787245c2a83b2de85579c82 (patch)
tree5f7698741b870f3f8f80f3083ffd3d1cd2e6f749 /sql/hive
parent5edbcbfb61703398a24ce5162a74aba04e365b0c (diff)
downloadspark-4df60a8cbc58f2877787245c2a83b2de85579c82.tar.gz
spark-4df60a8cbc58f2877787245c2a83b2de85579c82.tar.bz2
spark-4df60a8cbc58f2877787245c2a83b2de85579c82.zip
[SPARK-4529] [SQL] support view with column alias
Support view definition like CREATE VIEW view3(valoo) TBLPROPERTIES ("fear" = "factor") AS SELECT upper(value) FROM src WHERE key=86; [valoo as the alias of upper(value)]. This is missing part of SPARK-4239, for a fully view support. Author: Daoyuan Wang <daoyuan.wang@intel.com> Closes #3396 from adrian-wang/viewcolumn and squashes the following commits: 4d001d0 [Daoyuan Wang] support view with column alias
Diffstat (limited to 'sql/hive')
-rw-r--r--sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala2
-rw-r--r--sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUdfs.scala4
2 files changed, 3 insertions, 3 deletions
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
index b9283f668a..f4c42bbc5b 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
@@ -379,7 +379,7 @@ private[hive] object HiveQl {
protected def nameExpressions(exprs: Seq[Expression]): Seq[NamedExpression] = {
exprs.zipWithIndex.map {
case (ne: NamedExpression, _) => ne
- case (e, i) => Alias(e, s"c_$i")()
+ case (e, i) => Alias(e, s"_c$i")()
}
}
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUdfs.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUdfs.scala
index b255a2ebb9..fecf8faaf4 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUdfs.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUdfs.scala
@@ -279,7 +279,7 @@ private[hive] case class HiveGenericUdtf(
}
override protected def makeOutput() = {
- // Use column names when given, otherwise c_1, c_2, ... c_n.
+ // Use column names when given, otherwise _c1, _c2, ... _cn.
if (aliasNames.size == outputDataTypes.size) {
aliasNames.zip(outputDataTypes).map {
case (attrName, attrDataType) =>
@@ -288,7 +288,7 @@ private[hive] case class HiveGenericUdtf(
} else {
outputDataTypes.zipWithIndex.map {
case (attrDataType, i) =>
- AttributeReference(s"c_$i", attrDataType, nullable = true)()
+ AttributeReference(s"_c$i", attrDataType, nullable = true)()
}
}
}