我有一个 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)