我有一个Spark数据帧,有1行3列,即start_date,end_date,end_month_id。 我想从第一个单元格中检索值到变量中,并使用该变量来过滤另一个数据帧。
我想将'2019-01-01'检索到变量中。我怎么做? 这是我到目前为止:
start_date = df1[0];
df2.filter(df2.date_reported >= start_date)
我是菜鸟,所以请放轻松
试试这个。 take为您提供了一组行,您可以根据Row对象中的列名提取值。
val start_date = df1.take(1)(0).getAs[String]("start_date")