Merge branch 'SPOI-4520-JoinOp' into devel-3
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/fd2f42bd Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/fd2f42bd Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/fd2f42bd Branch: refs/heads/devel-3 Commit: fd2f42bd926d46f07d5717b2fcb614c6cf2abff5 Parents: 8331f56 fc547d8 Author: Chandni Singh <[email protected]> Authored: Fri Feb 26 15:17:51 2016 -0800 Committer: Chandni Singh <[email protected]> Committed: Fri Feb 26 15:17:51 2016 -0800 ---------------------------------------------------------------------- .../lib/join/AbstractJoinOperator.java | 435 +++++++++++++++++++ .../java/com/datatorrent/lib/join/Bucket.java | 91 ++++ .../com/datatorrent/lib/join/InMemoryStore.java | 107 +++++ .../com/datatorrent/lib/join/JoinStore.java | 91 ++++ .../datatorrent/lib/join/MapJoinOperator.java | 100 +++++ .../datatorrent/lib/join/POJOJoinOperator.java | 266 ++++++++++++ .../datatorrent/lib/join/TimeBasedStore.java | 333 ++++++++++++++ .../com/datatorrent/lib/join/TimeEvent.java | 50 +++ .../com/datatorrent/lib/join/TimeEventImpl.java | 121 ++++++ .../lib/join/MapTimeBasedJoinOperator.java | 118 +++++ .../lib/join/POJOTimeBasedJoinOperatorTest.java | 385 ++++++++++++++++ 11 files changed, 2097 insertions(+) ----------------------------------------------------------------------
