https://www.javacodegeeks.com/2018/02/apache-beam.html