group_by_hop_compact.sql 304 B

12345678910111213
  1. /* syntax version 1 */
  2. /* postgres can not */
  3. /* ytfile can not */
  4. /* yt can not */
  5. PRAGMA dq.AnalyticsHopping="true";
  6. SELECT
  7. user,
  8. HOP_START() as ts,
  9. SUM(payload) as payload
  10. FROM plato.Input
  11. GROUP COMPACT BY HOP(DateTime::FromSeconds(CAST(ts as Uint32)), "PT10S", "PT10S", "PT10S"), user;