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 <[email protected]> Authored: Tue Jul 12 15:51:28 2016 -0700 Committer: Siyuan Hua <[email protected]> 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(-) ----------------------------------------------------------------------
