Spark Structure Потоковое несколько окон агрегации - PullRequest
0 голосов
/ 06 февраля 2019

Я сейчас просыпаюсь при потоковой передаче искровой структуры, версия 2.11.Могу ли я выполнить агрегацию, используя два окна (одно по дням, другое по часам) только в одном запросе потоковой структуры?

Таблица результатов содержит как дневные, так и почасовые данные?

device_id | day | hour | daily_agg_data | hourly_agg_data
a            05     01     123              5
a            05     02     123              6
b            05     01     456              7
...