I keep digging, searching and can't quite find this use case anywhere.  We
receive a stream of 'file received' events and these files can be received
at the same time.  These files vary in size from 10 rows(simple) to 800,000
rows.

Ideally, we would like each file to end up in it's own window(I think) and
we would like to join each file with itself before sending downstream.
Some rows in the file error before we join and those go down an error
notification path.  The other rows, we join together.

Is there any sort of example on how to do this?  It is much like doing a
batch in the middle of streaming ideally.

thanks,
Dean Hiller (he/him <https://www.mypronouns.org/what-and-why>)
CTO & VP of Engineering
Orderly Health <http://orderlyhealth.com/>
Connect with me on LinkedIn! <https://www.linkedin.com/in/deanhiller/>

Reply via email to