时间戳

首页 > 解决方案 > 如何使用pyspark在每次迭代中将数据框结果保存在具有不同名称的配置单元表中

dataframe - 如何使用pyspark在每次迭代中将数据框结果保存在具有不同名称的配置单元表中

问题描述

我有一个数据框，我使用 saveAsTable 命令将结果存储在配置单元表中。我希望我的代码在多个国家/地区运行并将结果存储为每个国家/地区具有不同名称的表。

示例：假设我有一个带有国家/地区名称列表的变量

options=['AR', 'AT', 'AU', 'CA' ,'CH']
s=input("Enter your country code")
if s in options:
  country_cd=s
else:
 print("invalid country code")

现在基于 country_cd 变量我想将结果保存在 df

df.write.mode("overwrite").saveAsTable("amankeshar.table_{country_cd}")

该表应与国家名称一起存储。需要帮助来实现它。

标签： dataframepysparkapache-spark-sql

解决方案

推荐阅读