主页 / user-16743720

elokema's questions

Martin Hope
elokema
Asked: 2024-09-25 17:40:01 +0800 CST
  • 5

在 pyspark 中，我有这张表，我想获取到当前月份的所有过去月份 =‘九月’

一月 二月 行进 四月 可能 六月 七月 八月 九月 十月 十一月 十二月
10 20 三十 40 50 60 70 80 100 110 120 150

然后，我最后会得到这个表格：

一月 二月 行进 四月 可能 六月 七月 八月 九月
10 20 三十 40 50 60 70 80 100

这是我的代码：

months = ["January", "February", "March", "April", "May", "June", "July", "August", "September", "October", "November", "December"]

for month in months:
   if month < (F.month(F.current_date())):
      df = df.filter(F.col(month))
```
python
Martin Hope
elokema
Asked: 2024-08-30 23:08:48 +0800 CST
  • 5

我想在函数pyspark中写入这部分

df = (df.withColumn("January", F.lit(None).cast('double'))
        .withColumn("February", F.lit(None).cast('double'))
        .withColumn("March", F.lit(None).cast('double'))
        .withColumn("April", F.lit(None).cast('double'))
        .withColumn("May", F.lit(None).cast('double'))
        .withColumn("June", F.lit(None).cast('double'))
        .withColumn("July", F.lit(None).cast('double'))
        .withColumn("August", F.lit(None).cast('double'))
        .withColumn("September", F.lit(None).cast('double'))
        .withColumn("November", F.lit(None).cast('double'))
        .withColumn("December", F.lit(None).cast('double'))
pyspark