[SAMZA-1277] Add a static merge() operator that takes all streams to merge as input

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.13.0
• Assignee: Prateek Maheshwari
• Reporter: Jake Maes
• Created: 09/May/17 22:53
• Updated: 10/May/17 22:10
• Resolved: 10/May/17 22:10

Description

The current design forces users to do stuff like this (I can provide more than a few examples already)

List<MessageStream<GenericRecord>> xTrackingMonitoringEvents = new ArrayList<>();
// ... populate the list
 MessageStream<GenericRecord>  initialInputStream =
        xTrackingMonitoringEvents.remove(xTrackingMonitoringEvents.size() - 1);
    Collection<MessageStream<? extends GenericRecord>> otherStreams =
        (Collection<MessageStream<? extends GenericRecord>>) (Object) xTrackingMonitoringEvents;

    initialInputStream
        .merge(otherStreams)
// .do other stuff

^ eww. Removing one item from the array so it can be used as the initial message stream seems to cause pain.

Lets see if we can come up with a cleaner way to do merge()

Issue Links

• links to: GitHub Pull Request #182