How to call FileIO.Write.via(Contextful, Contextful) in Scala
I’m using Apache Beam with Scala. To create new ParquetIO.Sink instances with the respective schemas for the different types of streaming data, I’m trying to call .via(Contextful, Contextful) on …