计算结果的sparksql插入技术

jfewjypa  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(440)

或者我正在使用下面的代码-

spark.sql("INSERT INTO countDirectorySize VALUES (`" +str(root) + "`)")

完整的代码在这里更好的理解-

root = "/dbfs/mnt/datalake/.../"
spark.sql("INSERT INTO countDirectorySize VALUES (`" +str(root) + "`)")

此代码在插入时出错。任何帮助都会很好。
错误:

"cannot resolve '`/dbfs/mnt/datalake/.../`' given input columns: []; 
line 1 pos 30;\n'InsertIntoTable 'UnresolvedRelation `countSize`, false, false\n+- 'UnresolvedInlineTable [col1], [List('/dbfs/mnt/datalake/.../)]\n"
jhdbpxl9

jhdbpxl91#

这种安排奏效了。只是 ('"____"') 我只想知道。

spark.sql("INSERT INTO countDirectorySize VALUES ('"+str(root)+"')")

相关问题