Spark SQL中按日期分组聚合

我通过添加以下功能解决了该问题：

def convert( time:Long ) : String = {  val sdf = new java.text.SimpleDateFormat("yyyy-MM-dd")  return sdf.format(new java.util.Date(time))}

并将其注册到sqlContext中，如下所示：

sqlContext.registerFunction("convert", convert _)

然后，我终于可以按日期分组：

select * from table convert(time)