more permisive checking for function registration

marmbrus · marmbrus · commit e7b3941669bf · 2015-05-06T21:26:51.000Z
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala
@@ -407,7 +407,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
   }
 
   protected[hive] def runSqlHive(sql: String): Seq[String] = {
-    if (sql.toLowerCase.startsWith("create temporary function")) {
+    if (sql.toLowerCase.contains("create temporary function")) {
       executionHive.runSqlHive(sql)
     } else if (sql.trim.toLowerCase.startsWith("set")) {
       metadataHive.runSqlHive(sql)

Original file line number	Diff line number	Diff line change
`@@ -407,7 +407,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {`
`407`	`407`	`}`
`408`	`408`
`409`	`409`	`protected[hive] def runSqlHive(sql: String): Seq[String] = {`
`410`		`- if (sql.toLowerCase.startsWith("create temporary function")) {`
	`410`	`+ if (sql.toLowerCase.contains("create temporary function")) {`
`411`	`411`	`executionHive.runSqlHive(sql)`
`412`	`412`	`} else if (sql.trim.toLowerCase.startsWith("set")) {`
`413`	`413`	`metadataHive.runSqlHive(sql)`