group_by_session_nopush.sql 348 B

1234567891011121314
  1. /* syntax version 1 */
  2. /* postgres can not */
  3. /* yt can not */
  4. SELECT * FROM (
  5. SELECT
  6. user,
  7. cast(session_start as Int64) as ss,
  8. ListSort(AGGREGATE_LIST(ts)) as session,
  9. COUNT(1) as session_len
  10. FROM plato.Input
  11. GROUP BY SessionWindow(ts, 10) as session_start, user
  12. )
  13. WHERE ss != 100500; -- should not push down