US20160132367A1 - System and Method for Linearizing Messages from Data Sources for Optimized High-Performance Processing in a Stream Processing System