SparkSql 不支持Date Format (支持Timestamp)


最近项目中需要用到sparksql ,需要查询sql Date类型, 无奈,官方现阶段 1.6.0 还不支持Date类型,不过支持Timestamp类型,所以问题可以解决了。

1.解析

SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date beginDate = null;
Date endDate = null;
try {
    beginDate = (Date) dateFormat.parse(param3[0]);
    endDate = dateFormat.parse(param3[1]);
} catch (ParseException e) {
    e.printStackTrace();
}
System.out.println("beginDate.getTime()"+ beginDate.getTime()+"-----" + endDate.getTime());

String sql = "SELECT * FROM carMonitorBean WHERE DCOLLECTIONDATE >= " + beginDate.getTime() + " AND DCOLLECTIONDATE <="
        +endDate.getTime()+ " AND HOURTIME >=3 AND HOURTIME <=5";

 

2. spark Sql 可以参看官网提供的文档如下:

http://spark.apache.org/docs/latest/sql-programming-guide.html#sql

如对您有帮助,请多多支持。


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM