Hi Community, Right now, the WindowedStream in the pull request has following "window" transformations:
count countByKey top topByKey combine combineByKey fold foldByKey group groupByKey Do you have other suggestions that are nice to have in the WindowedStream interface. Also I think it might be a good idea to further divide WindowedStream to KeyedWindowedStream so developer can define some custom function to convert normal tuple to KeyValuePair that is required by xxxByKey methods. Any ideas on that? Regards, Siyuan
