HI All, I just want to run some spark structured streaming Job similar to this
DS.filter(col("name").equalTo("john")) .groupBy(functions.window(df1.col("TIMESTAMP"), "24 hours", "24 hours"), df1.col("hourlyPay")) .agg(sum("hourlyPay").as("total")); I am wondering if I can express the above query in raw sql string? If so how would that look like and what are some of the disadvantages of using raw sql query vs spark DSL? Thanks!