Hello all, I have picked up and updated KIP-150. Due to changes to the project since KIP #150 was written there are a few items that need to be updated.
First item that changed is the adoption of the Materialized parameter. The second item is the WindowedBy. How the old KIP handles windowing is that it overloads the aggregate function to take in a Window object as well as the other parameters. The current practice to window grouped-streams is to call windowedBy and receive a windowed stream object. The existing interface for a windowed stream made from a grouped stream will not work for cogrouped streams. Hence, we have to make new interfaces for cogrouped windowed streams. Please take a look, I would like to hear your feedback, Walker
