我在试图使用包含我的表达式的变量时遇到了问题,这个变量包含了一个数据文件的selectExpr。substr(value,1,1) as qffffffffbf3ef0cf","substr(value,2,1) as q6a0aaf20"'ascii_df.selectExpr如果我按下面的方式将表达式直接放入其中,它就会工作:
ascii_df.selectExpr("substr(value,1,1) as qffffffffbf3ef0cf&
我正在动态地生成一个查询字符串,如下所示,并将其传递给selectExpr()。''''category_id as cat_id','category_department_id as cat_dpt_id','category_name as cat_name''''按照文件
selectExpr(*expr):项目一组SQL表达式并返回一个新的DataFrame
我想将类似2019-03-25T00:27:46.985-0500的时间戳转换为格式2019-03-25 00:27:46 使用Spark v2.3.0 Scala v2.11.8 time ColA ColB ColC 2019-03-25T00:27:46.985-0500 A B C 2019-03-25T00:27:46.960-0500 A B C 2019-03-25T00:27:46.839-0500 A B C 2019-03-25T00:27:46.596-0500 A B C 2019-03-25T00:27:46.559-0500 A B C 2019-03-25T00