Hi All,
I get the following exception when I run the query below. Not sure what the cause is? "Non-time-based windows are not supported on streaming DataFrames/Datasets;" My TIME_STAMP field is of string type. dataset .sqlContext() .sql("select count(distinct ID), sum(AMOUNT) from (select *, row_number() over (partition by ID order by TIME_STAMP desc) r from events) x where r=1 group by NAME, EVENT_CODE"); Thanks, kant