[STORM-245] Implement localOrShuffle() on Stream for performance

• Type: New Feature
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.9.2-incubating
• Component/s: storm-core
• Labels: performance trident
• Assignee: P. Taylor Goetz
• Reporter: Rob Turner
• Created: 25/Feb/14 19:48
• Updated: 09/Oct/15 01:02
• Resolved: 19/May/14 21:27

Description

Stream has a shuffle() method but does not have a localOrShuffle() method to prevent cross worker serialization if possible.