星火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]