aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorYin Huai <yhuai@databricks.com>2015-06-02 09:59:19 -0700
committerYin Huai <yhuai@databricks.com>2015-06-02 09:59:19 -0700
commit8c3fc3a6cd3fe05b018733c68691837de3b06f4a (patch)
tree59e0dce4aac63acc45cc5cb9358298ff9b10ef83 /sql
parent97fedf1a0297a4daae4e7b18181c08789383ad55 (diff)
downloadspark-8c3fc3a6cd3fe05b018733c68691837de3b06f4a.tar.gz
spark-8c3fc3a6cd3fe05b018733c68691837de3b06f4a.tar.bz2
spark-8c3fc3a6cd3fe05b018733c68691837de3b06f4a.zip
[HOT-FIX] Add EvaluatedType back to RDG
https://github.com/apache/spark/commit/87941ff8c49a6661f22c31aa7b84ac1fce768135 accidentally removed the EvaluatedType. Author: Yin Huai <yhuai@databricks.com> Closes #6589 from yhuai/getBackEvaluatedType and squashes the following commits: 618c2eb [Yin Huai] Add EvaluatedType back.
Diffstat (limited to 'sql')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/random.scala2
1 files changed, 2 insertions, 0 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/random.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/random.scala
index b2647124c4..5677037dcc 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/random.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/random.scala
@@ -38,6 +38,8 @@ abstract class RDG(seed: Long) extends LeafExpression with Serializable {
*/
@transient protected lazy val rng = new XORShiftRandom(seed + TaskContext.get().partitionId())
+ override type EvaluatedType = Double
+
override def deterministic: Boolean = false
override def nullable: Boolean = false