aboutsummaryrefslogtreecommitdiff
path: root/dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala
diff options
context:
space:
mode:
Diffstat (limited to 'dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala')
-rw-r--r--dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala8
1 files changed, 4 insertions, 4 deletions
diff --git a/dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala b/dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala
index a21410f3b9..5111bc0adb 100644
--- a/dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala
+++ b/dev/audit-release/sbt_app_hive/src/main/scala/HiveApp.scala
@@ -37,10 +37,10 @@ object SparkSqlExample {
val hiveContext = new HiveContext(sc)
import hiveContext._
- hql("DROP TABLE IF EXISTS src")
- hql("CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")
- hql("LOAD DATA LOCAL INPATH 'data.txt' INTO TABLE src")
- val results = hql("FROM src SELECT key, value WHERE key >= 0 AND KEY < 5").collect()
+ sql("DROP TABLE IF EXISTS src")
+ sql("CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")
+ sql("LOAD DATA LOCAL INPATH 'data.txt' INTO TABLE src")
+ val results = sql("FROM src SELECT key, value WHERE key >= 0 AND KEY < 5").collect()
results.foreach(println)
def test(f: => Boolean, failureMsg: String) = {