Предложение where здесь не работает из-за orderBy, есть ли обходной путь к этому? - PullRequest
0 голосов
/ 01 мая 2019

Предложение where здесь не работает из-за orderBy. Есть ли обходной путь к этому?

new_subs_df = new_subs_df.withColumn(
    'last_x_date', 
    lag(col("x_date").over(
        Window.partitionBy('user_id')\
       .orderBy(
           to_date(col('z_date'),None).asc(),
           to_date(col('y_date'),None).asc()
        )\
        .where(col('event_type') != '1')
    )
)

1 Ответ

0 голосов
/ 01 мая 2019

w = Window.partitionBy ('user_id'). OrderBy ('z_date', 'y_date')

new_subs_df = new_subs_df.filter (new_subs_df.event_type! = '1'). Select ('user_id', F.lag ( "x_date"). Над (ш) .alias ( "last_x_date"))

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...