星火SQL模擬「SYSDATE」或「CURRENT_DATE」

Question

有它在星火SQL支持獲取當前日期的任何日期的功能？

Answer 1

，我發現我的問題的解決方案在使用org.apache.spark.sql.hive.HiveContext代替org.apache.spark.sql.SQLContext。現在，下面的代碼按預期工作：

lazy val sc = ... // create Spak Context 
lazy val hc = new HiveContext(sc) 
val results = hc.sql("SELECT record_name as name FROM test_table WHERE day < current_date") 
results.take(10) 
    .map(r => s"name: ${r.getAs("name")}") 
    .foreach(println) 

Answer 2

CURRENT_DATE（）爲我工作在星火1.5

用法示例：

sqlContext.sql("SELECT current_date() as today FROM eventsAvro").first 

輸出：

res360: org.apache.spark.sql.Row = [2016-01-29]