连续行之间的日期差-Pyspark数据框

连续行之间的日期差-Pyspark数据框

像这样：

df.registerTempTable("df")sqlContext.sql("""     SELECt *, CAST(date AS bigint) - CAST(lag(date, 1) OVER (   PARTITION BY user_id ORDER BY date) AS bigint)      FROM df""")