You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@apex.apache.org by Siyuan Hua <si...@datatorrent.com> on 2016/07/01 20:29:06 UTC

Suggestions for WindowedStream interface in the next phase

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