Testing and Validating distributed systems with Apache Spark and Apache Beam