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!

Reply via email to