You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The use case is - creating a WindowStream out of any other stream with ability to decide how each window frame content is grouped. And in the context of the above proposal it could be:
anyStream.batch(3,2).as(WindowStream)
The text was updated successfully, but these errors were encountered:
Feature description
In
v4
.batch()
is a simple transform which groups chunks by a given number:and in
pre-v5
it accepts a callback but we plan to introduce batching by amount the same asv4
too.Now, it could be extended by adding optional
step
param which will allow to change how chunks are grouped:Use case
The use case is - creating a
WindowStream
out of any other stream with ability to decide how each window frame content is grouped. And in the context of the above proposal it could be:The text was updated successfully, but these errors were encountered: