Processing Time Windowed Data with Apache Beam and Cloud Dataflow (Java)