SAMZA-1247: MessageStreamImpl#merge shouldn't mutate input collection
authorPrateek Maheshwari <pmaheshw@linkedin.com>
Thu, 4 May 2017 19:28:58 +0000 (12:28 -0700)
committerJacob Maes <jmaes@linkedin.com>
Thu, 4 May 2017 19:28:58 +0000 (12:28 -0700)
commit435d4fe1f9caf7dd310a788e8158bc94c3f23878
tree07c3d75dc57974550895208317955a9c9c4f8c09
parentf99de20cca3bde199742290e9b54b6776e7ee46d
SAMZA-1247: MessageStreamImpl#merge shouldn't mutate input collection

Also fixes
SAMZA-1253: MessageStream.merge operator broken for nested types

Author: Prateek Maheshwari <pmaheshw@linkedin.com>

Reviewers: Jacob Maes <jmaes@linkedin.com>, Jagadish <jvenkatr@linkedin.com>

Closes #159 from prateekm/merge-fixes
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java
samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java