multiaggr_subq.sql.txt 294 B

1234567891011
  1. import agg_factory symbols $factory;
  2. use plato;
  3. define subquery $multiaggr_win() as
  4. select
  5. MULTI_AGGREGATE_BY(AsStruct(subkey as a,value as b), $factory) over w as ma,
  6. ROW_NUMBER() over w as rn
  7. from Input window w as (order by key);
  8. end define;
  9. export $multiaggr_win;