[rocketmq-streams] branch develop updated (f546c009 -> fbe1967f)

[ka...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

karp pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


    from f546c009 Merge pull request #273 from apache/local/upstream/develop
     new a43e4672 Add min & max func
     new d8c8ad15 Add example
     new 20415829 refactor format
     new d67903c5 support sum
     new 4844f3b2 refactor example
     new fbe1967f Merge pull request #275 from joeCarf/support_min_function

The 765 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../streams/core/rstream/GroupedStreamImpl.java    |  4 +-
 .../streams/core/rstream/WindowStream.java         |  7 ++
 .../streams/core/rstream/WindowStreamImpl.java     | 81 +++++++++++++++++++++-
 .../examples/pojo/{User.java => Grade.java}        | 46 ++++++------
 .../window/{WindowCount.java => WindowMin.java}    | 27 ++++----
 .../window/{WindowCount.java => WindowSum.java}    | 27 ++++----
 6 files changed, 139 insertions(+), 53 deletions(-)
 copy example/src/main/java/org/apache/rocketmq/streams/examples/pojo/{User.java => Grade.java} (64%)
 copy example/src/main/java/org/apache/rocketmq/streams/examples/window/{WindowCount.java => WindowMin.java} (79%)
 copy example/src/main/java/org/apache/rocketmq/streams/examples/window/{WindowCount.java => WindowSum.java} (79%)