Building advanced Beam pipelines in Scala with SCIO