SAMZA-1277: Add a static merge() operator that takes all streams to merge as input
authorPrateek Maheshwari <pmaheshw@linkedin.com>
Wed, 10 May 2017 22:10:02 +0000 (15:10 -0700)
committerJacob Maes <jmaes@linkedin.com>
Wed, 10 May 2017 22:10:02 +0000 (15:10 -0700)
commit36b2f23bb706dfa1cc75fcddf5866cd66e6de623
treeeb364488810dee43c8ed26cbcd5138f86e60b124
parent601c11d873e3316aea538f2e0c51ac4a3c1648e7
SAMZA-1277: Add a static merge() operator that takes all streams to merge as input

Also updated documentation for join and partitionBy.

Author: Prateek Maheshwari <pmaheshw@linkedin.com>

Reviewers: Jacob Maes <jmaes@linkedin.com>

Closes #182 from prateekm/documentation-cleanup
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
samza-core/src/test/java/org/apache/samza/example/MergeExample.java [new file with mode: 0644]
samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java