В моем приложении я хочу собирать и группировать данные в несколько сегментов (скажем, 1 м, 10 м, 1 час и 4 часа).В Kinesis Data Analytics падающие окна кажутся подходящими.Тем не менее, я хочу, чтобы самые последние окна для каждого сегмента выдавали частичные данные, то есть в 02:12:30 сегмент 1 м должен содержать последние 30 с данных, контейнер 10 м должен содержать последние 2 м данных, искоро.Это нормально, если эти частичные данные будут передаваться с интервалом, если это необходимо.
Кажется, что это больше соответствует поведению скользящего окна, чем поворотному окну, но, насколько я могу судить, скользящие окна нельзя задавать пошагововремя начала, только постоянные интервалы, и я не хочу, чтобы частичные данные перекрывались с предыдущим сегментом.
Возможен ли этот шаблон с потоковым SQL AWS, или мне потребуется реализовать собственную лямбду для этой агрегации