SparkSQL

1. 框架规格应以关键字开头，

   ROWS

   而不是

   ROW

2. 框架规格要求下限值

   ROWS BETWEEN 1 PRECEDING AND CURRENT ROW

或

UNBOUNDED

    ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW

1. LAG

   函数根本不接受框架，因此带有滞后的正确SQL查询看起来像这样

   SELECt tx.cc_num,tx.trans_date,tx.trans_time,tx.amt, LAG(tx.amt) OVER ( PARTITION BY tx.cc_num ORDER BY  tx.trans_date,tx.trans_time

   ) as prev_amt from tx

编辑 ：

关于SQL DSL使用：

1. 正如您所读的错误消息

注意，使用窗口函数当前需要一个HiveContex

请务必

sqlContext

HiveContext

SQLContext

1. windowSpec.rowsBetween(-1, 0)

   什么都不做，但是功能再次不支持帧说明

   lag

   。