[rocketmq-streams] branch develop updated (7c0ceee4 -> b5355dec)

[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 7c0ceee4 Merge pull request #266 from ni-ze/develop
     new daf22d73 [ISSUE #251]Support avg function in WindowStream
     new 6e17ed81 Merge branch 'develop' into develop_avg
     new e6eec5de [ISSUE #251] Update windowAvg examples
     new 652c9acf Merge branch 'develop' into develop_avg
     new b5355dec Merge pull request #259 from Jargon9/develop_avg

The 740 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:
 .../{MinAccumulator.java => AvgAccumulator.java}   | 49 +++++++++++++++-------
 .../streams/core/rstream/WindowStream.java         |  2 +
 .../streams/core/rstream/WindowStreamImpl.java     | 19 +++++++++
 .../streams/core/util/OperatorNameMaker.java       |  1 +
 .../{SessionWindowCount.java => WindowAvg.java}    | 34 ++++++++-------
 5 files changed, 75 insertions(+), 30 deletions(-)
 copy core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/{MinAccumulator.java => AvgAccumulator.java} (52%)
 copy example/src/main/java/org/apache/rocketmq/streams/examples/window/{SessionWindowCount.java => WindowAvg.java} (72%)