How to process stream data on Apache Beam