aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala
diff options
context:
space:
mode:
Diffstat (limited to 'sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala5
1 files changed, 3 insertions, 2 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala
index 6469e501c1..8f9c52cb1e 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/internal/CatalogSuite.scala
@@ -75,9 +75,10 @@ class CatalogSuite
}
private def createTempFunction(name: String): Unit = {
- val info = new ExpressionInfo("className", name)
val tempFunc = (e: Seq[Expression]) => e.head
- sessionCatalog.createTempFunction(name, info, tempFunc, ignoreIfExists = false)
+ val funcMeta = CatalogFunction(FunctionIdentifier(name, None), "className", Nil)
+ sessionCatalog.registerFunction(
+ funcMeta, ignoreIfExists = false, functionBuilder = Some(tempFunc))
}
private def dropFunction(name: String, db: Option[String] = None): Unit = {