Я написал этот код в потоковом приложении Kafka: KGroupedStream < String, foo > groupedStream = stream.groupByKey (); groupedStream.windowedBy (SessionWindows.with (Duration.ofSeconds (3)) ....

Я работаю над некоторым кодом на C#, связанным с проблемами типа скользящих средних, где мне часто нужно взять List / IEnumerable и работать с кусками последовательных данных. В модуле F# Seq есть отличная функция, ...