Processing Time Windowed Data with Apache Beam and Cloud Dataflow (Java)
01
Description
Deploy a Java application using Maven to process data with Cloud Dataflow. The Java application implements time-windowed aggregation to augment the raw data in order to produce consistent training and test datasets.
Google QwikLabs
Processing Time Windowed Data with Apache Beam and Cloud Dataflow (Java)