小编bat*_*ial的帖子

如何使用小部件在 Dataframe select 语句中传递动态列名称

我有一个 Dataframe,我想通过 Databricks Notebook 中的 select 语句中的小部件动态传递列名称。我该怎么做?

我正在使用下面的代码

df1 = spark.sql("select * from tableraw")
Run Code Online (Sandbox Code Playgroud)

其中df1有列“tablename”和“layer”

df = df1.select("tablename", "layer")
Run Code Online (Sandbox Code Playgroud)

现在,我们的要求是使用小部件的值来选择这些列,如下所示:

df = df1.select(dbutils.widget.get("tablename"), dbutils.widget.get("datalayer"))
Run Code Online (Sandbox Code Playgroud)

sql scala pyspark databricks azure-databricks

4
推荐指数
1
解决办法
2万
查看次数

标签 统计

azure-databricks ×1

databricks ×1

pyspark ×1

scala ×1

sql ×1