获取Spark Dataframe中特定单元格的值

问题描述 投票:0回答:1

我有一个Spark数据帧,有1行3列,即start_date,end_date,end_month_id。 我想从第一个单元格中检索值到变量中,并使用该变量来过滤另一个数据帧。 enter image description here

我想将'2019-01-01'检索到变量中。我怎么做? 这是我到目前为止:

start_date = df1[0];
df2.filter(df2.date_reported >= start_date)

我是菜鸟,所以请放轻松

apache-spark dataframe pyspark apache-spark-sql
1个回答
0
投票

试试这个。 take为您提供了一组行,您可以根据Row对象中的列名提取值。

val start_date = df1.take(1)(0).getAs[String]("start_date")
© www.soinside.com 2019 - 2024. All rights reserved.