Windowing streams on Vector?

[igr001-galactica]

I have worked with Kafka Streams in the past where I have been able to define a rolling time window in which to do transformations/filters/aggregations. Is something similar possible on Vector?
I would like to define a rolling time window, say 1 minute and perform some deduplications.

[jszwedko]

Hi @igr001-galactica !

The reduce transform does operate sort of like that, to collapse multiple logs into one based on conditions (like time), but generally Vector doesn't have great support for rolling window aggregation like that yet. It is something we are thinking about though. For example: #1329

[JeanMertz]

Closing in favour of the linked tracking issue at #1329.