Reduce data stream processing time