spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kant kodali <kanth...@gmail.com>
Subject Non-time-based windows are not supported on streaming DataFrames/Datasets;;
Date Wed, 06 Sep 2017 20:40:53 GMT
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

Mime
View raw message