aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2015-05-01 12:49:02 -0700
committerXiangrui Meng <meng@databricks.com>2015-05-01 12:49:02 -0700
commit37537760d19eab878a5e1a48641cc49e6cb4b989 (patch)
treea37c553f7c27835399dd46a26fafd8dcc1613437 /sql/catalyst
parent16860327286bc08b4e2283d51b4c8fe024ba5006 (diff)
downloadspark-37537760d19eab878a5e1a48641cc49e6cb4b989.tar.gz
spark-37537760d19eab878a5e1a48641cc49e6cb4b989.tar.bz2
spark-37537760d19eab878a5e1a48641cc49e6cb4b989.zip
[SPARK-7274] [SQL] Create Column expression for array/struct creation.
Author: Reynold Xin <rxin@databricks.com> Closes #5802 from rxin/SPARK-7274 and squashes the following commits: 19aecaa [Reynold Xin] Fixed unicode tests. bfc1538 [Reynold Xin] Export all Python functions. 2517b8c [Reynold Xin] Code review. 23da335 [Reynold Xin] Fixed Python bug. 132002e [Reynold Xin] Fixed tests. 56fce26 [Reynold Xin] Added Python support. b0d591a [Reynold Xin] Fixed debug error. 86926a6 [Reynold Xin] Added test suite. 7dbb9ab [Reynold Xin] Ok one more. 470e2f5 [Reynold Xin] One more MLlib ... e2d14f0 [Reynold Xin] [SPARK-7274][SQL] Create Column expression for array/struct creation.
Diffstat (limited to 'sql/catalyst')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala10
1 files changed, 9 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala
index 2225621dba..c6217f07c4 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala
@@ -28,13 +28,21 @@ import org.apache.spark.sql.catalyst.trees
* the layout of intermediate tuples, BindReferences should be run after all such transformations.
*/
case class BoundReference(ordinal: Int, dataType: DataType, nullable: Boolean)
- extends Expression with trees.LeafNode[Expression] {
+ extends NamedExpression with trees.LeafNode[Expression] {
type EvaluatedType = Any
override def toString: String = s"input[$ordinal]"
override def eval(input: Row): Any = input(ordinal)
+
+ override def name: String = s"i[$ordinal]"
+
+ override def toAttribute: Attribute = throw new UnsupportedOperationException
+
+ override def qualifiers: Seq[String] = throw new UnsupportedOperationException
+
+ override def exprId: ExprId = throw new UnsupportedOperationException
}
object BindReferences extends Logging {