You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/11/15 06:04:21 UTC
spark git commit: [SPARK-11736][SQL] Add monotonically_increasing_id
to function registry.
Repository: spark
Updated Branches:
refs/heads/master 22e96b87f -> d83c2f9f0
[SPARK-11736][SQL] Add monotonically_increasing_id to function registry.
https://issues.apache.org/jira/browse/SPARK-11736
Author: Yin Huai <yh...@databricks.com>
Closes #9703 from yhuai/MonotonicallyIncreasingID.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d83c2f9f
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d83c2f9f
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d83c2f9f
Branch: refs/heads/master
Commit: d83c2f9f0b08d6d5d369d9fae04cdb15448e7f0d
Parents: 22e96b8
Author: Yin Huai <yh...@databricks.com>
Authored: Sat Nov 14 21:04:18 2015 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sat Nov 14 21:04:18 2015 -0800
----------------------------------------------------------------------
.../apache/spark/sql/catalyst/analysis/FunctionRegistry.scala | 3 ++-
.../test/scala/org/apache/spark/sql/ColumnExpressionSuite.scala | 4 ++++
2 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/d83c2f9f/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
index 870808a..a8f4d25 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
@@ -281,7 +281,8 @@ object FunctionRegistry {
expression[Sha1]("sha1"),
expression[Sha2]("sha2"),
expression[SparkPartitionID]("spark_partition_id"),
- expression[InputFileName]("input_file_name")
+ expression[InputFileName]("input_file_name"),
+ expression[MonotonicallyIncreasingID]("monotonically_increasing_id")
)
val builtin: SimpleFunctionRegistry = {
http://git-wip-us.apache.org/repos/asf/spark/blob/d83c2f9f/sql/core/src/test/scala/org/apache/spark/sql/ColumnExpressionSuite.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/ColumnExpressionSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/ColumnExpressionSuite.scala
index 010df2a..8674da7 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/ColumnExpressionSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/ColumnExpressionSuite.scala
@@ -563,6 +563,10 @@ class ColumnExpressionSuite extends QueryTest with SharedSQLContext {
df.select(monotonicallyIncreasingId()),
Row(0L) :: Row(1L) :: Row((1L << 33) + 0L) :: Row((1L << 33) + 1L) :: Nil
)
+ checkAnswer(
+ df.select(expr("monotonically_increasing_id()")),
+ Row(0L) :: Row(1L) :: Row((1L << 33) + 0L) :: Row((1L << 33) + 1L) :: Nil
+ )
}
test("sparkPartitionId") {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org