apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hsy...@apache.org
Subject [4/4] apex-malhar git commit: Merge branch 'windowedOperator' of https://github.com/davidyan74/incubator-apex-malhar
Date Tue, 12 Jul 2016 22:52:02 GMT
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 <hsy541@apache.org>
Authored: Tue Jul 12 15:51:28 2016 -0700
Committer: Siyuan Hua <hsy541@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(-)
----------------------------------------------------------------------



Mime
View raw message