Итак, в принципе, позволяет ли потоковая передача с искрой (или даже потоковая передача с искровой структурой) концепцию окон, которые начинаются с начала потока и обновляются / создаются при появлении новой записи?
Я знаю, что он работает для пакетной обработки, но тот же API, который не работает с потоковой передачей искр, похоже.