Merge branch 'APEXMALHAR-2100-InnerJoin' of https://github.com/chaithu14/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/822323d0 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/822323d0 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/822323d0 Branch: refs/heads/master Commit: 822323d02725ddf24dfe725c4a57aa05b5d4b165 Parents: e44caa5 fe2da3e Author: Chinmay Kolhatkar <[email protected]> Authored: Wed Aug 24 13:30:34 2016 +0530 Committer: Chinmay Kolhatkar <[email protected]> Committed: Wed Aug 24 13:30:34 2016 +0530 ---------------------------------------------------------------------- .../lib/join/AbstractInnerJoinOperator.java | 340 ++++++++++++++++++ .../AbstractManagedStateInnerJoinOperator.java | 253 +++++++++++++ .../apex/malhar/lib/join/JoinStreamCodec.java | 46 +++ .../malhar/lib/join/POJOInnerJoinOperator.java | 246 +++++++++++++ .../state/managed/AbstractManagedStateImpl.java | 4 +- .../managed/ManagedTimeStateMultiValue.java | 353 +++++++++++++++++++ .../lib/join/POJOInnerJoinOperatorTest.java | 351 ++++++++++++++++++ .../lib/join/POJOPartitionJoinOperatorTest.java | 194 ++++++++++ 8 files changed, 1786 insertions(+), 1 deletion(-) ----------------------------------------------------------------------
