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 86f18192 Merge pull request #260 from ni-ze/develop
new ca82d3b1 idle window 0.1
new 16e1f3ea idle window 0.2
new d5db2a22 idle window 0.3
new 1dd13c3c modify windowCount example
new b9fe94d0 Merge pull request #262 from ni-ze/develop
The 727 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:
.../rocketmq/streams/core/common/Constant.java | 2 +
.../supplier/JoinWindowAggregateSupplier.java | 115 ++-------
.../supplier/WindowAccumulatorSupplier.java | 125 +++------
.../function/supplier/WindowAggregateSupplier.java | 113 +++------
.../core/running/AbstractWindowProcessor.java | 16 +-
.../streams/core/running/StreamContext.java | 5 +
.../streams/core/running/StreamContextImpl.java | 32 ++-
.../streams/core/running/WorkerThread.java | 13 +-
.../streams/core/window/IdleWindowScaner.java | 281 +++++++++++++++++++++
.../apache/rocketmq/streams/core/window/Time.java | 7 +-
.../rocketmq/streams/core/window/WindowKey.java | 31 +++
.../rocketmq/streams/core/window/WindowStore.java | 18 +-
.../window/fire/AccumulatorSessionWindowFire.java | 92 +++++++
.../core/window/fire/AccumulatorWindowFire.java | 95 +++++++
.../window/fire/AggregateSessionWindowFire.java | 88 +++++++
.../core/window/fire/AggregateWindowFire.java | 86 +++++++
.../fire/JoinWindowFire.java} | 178 +++++--------
.../fire/WindowFire.java} | 15 +-
core/src/main/resources/logback.xml | 2 +-
.../streams/examples/joinWindow/JoinWindow.java | 8 +-
.../rocketmq/streams/examples/pojo/Demo.java | 6 +
.../streams/examples/sink/WordCountSink.java | 13 +-
.../examples/window/SessionWindowCount.java | 8 +-
.../streams/examples/window/SlideWindowCount.java | 9 +-
.../streams/examples/window/WindowCount.java | 17 +-
.../streams/examples/window/WindowWordCount.java | 11 +-
26 files changed, 957 insertions(+), 429 deletions(-)
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/IdleWindowScaner.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java
copy
core/src/main/java/org/apache/rocketmq/streams/core/{function/supplier/JoinWindowAggregateSupplier.java
=> window/fire/JoinWindowFire.java} (50%)
copy
core/src/main/java/org/apache/rocketmq/streams/core/{serialization/KeyValueDeserializer.java
=> window/fire/WindowFire.java} (67%)
