执行sqlcontext.sql查询Spark Python时强制转换为字符串

问题描述

我正在运行此脚本，

dayfilename = (datetime.strptime(day,'%d-%m-%Y') + timedelta(days=-1)).strftime(format='%d%m%Y')
dayfilename = str(dayfilename)
query = "select t1.a as val1,{} as val2 from table1 t1".format(dayfilename)
df = sqlContext.sql(query)

我得到了输出

+------------+-------+
|        val1|   val2|
+------------+-------+
|919955123456|7102020|
|919955123456|7102020|
+------------+-------+

我希望该值为07102020

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）