我有一个dataframe,我想通过databricks笔记本中select语句中的小部件动态传递列名。我该怎么做?
我正在使用下面的代码
df1 = spark.sql("select * from tableraw")
哪里 df1
有“tablename”和“layer”列
df = df1.select("tablename", "layer")
现在,我们的要求是使用小部件的值来选择这些列,例如:
df = df1.select(dbutils.widget.get("tablename"), dbutils.widget.get("datalayer"))
1条答案
按热度按时间cczfrluj1#
python/scala
创建小部件
从小部件中提取值
使用值选择列
sql语句
与python/scala相比,sql中的小部件的工作原理稍有不同,因为您不能使用它们来选择列。但是,小部件可以用来动态调整过滤器。
创建小部件
将小部件值应用于筛选语句
更多的背景资料可以在小部件上的databricks文档中找到。