You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by hs...@apache.org on 2016/07/12 22:52:02 UTC
[4/4] apex-malhar git commit: Merge branch 'windowedOperator' of
https://github.com/davidyan74/incubator-apex-malhar
Merge branch 'windowedOperator' of https://github.com/davidyan74/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/67b84dda
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/67b84dda
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/67b84dda
Branch: refs/heads/master
Commit: 67b84dda4523feafc50117266cba132a593928cd
Parents: 883153f 7a77274
Author: Siyuan Hua <hs...@apache.org>
Authored: Tue Jul 12 15:51:28 2016 -0700
Committer: Siyuan Hua <hs...@apache.org>
Committed: Tue Jul 12 15:51:28 2016 -0700
----------------------------------------------------------------------
.../lib/testbench/CollectorTestSink.java | 10 +-
.../apex/malhar/lib/window/Accumulation.java | 76 +
.../apex/malhar/lib/window/ControlTuple.java | 42 +
.../malhar/lib/window/JoinAccumulation.java | 65 +
.../lib/window/SessionWindowedStorage.java | 47 +
.../apex/malhar/lib/window/TriggerOption.java | 278 +
.../apache/apex/malhar/lib/window/Tuple.java | 136 +
.../apache/apex/malhar/lib/window/Window.java | 194 +
.../apex/malhar/lib/window/WindowOption.java | 137 +
.../apex/malhar/lib/window/WindowState.java | 45 +
.../malhar/lib/window/WindowedKeyedStorage.java | 79 +
.../malhar/lib/window/WindowedOperator.java | 133 +
.../apex/malhar/lib/window/WindowedStorage.java | 91 +
.../window/impl/AbstractWindowedOperator.java | 512 +
.../impl/InMemoryWindowedKeyedStorage.java | 101 +
.../window/impl/InMemoryWindowedStorage.java | 89 +
.../window/impl/KeyedWindowedOperatorImpl.java | 174 +
.../malhar/lib/window/impl/WatermarkImpl.java | 53 +
.../lib/window/impl/WindowedOperatorImpl.java | 80 +
.../apex/malhar/lib/window/SumAccumulation.java | 59 +
.../malhar/lib/window/WindowedOperatorTest.java | 550 +
.../lib/window/sample/pi/Application.java | 127 +
.../window/sample/wordcount/Application.java | 157 +
library/src/test/resources/wordcount.txt | 16271 +++++++++++++++++
24 files changed, 19505 insertions(+), 1 deletion(-)
----------------------------------------------------------------------