Hi Beam Devs, Alejandro, copied, is an enthusiastic developer, who recently coded up: https://github.com/elbaulp/DPASF (associated paper found: https://arxiv.org/abs/1810.06021).
He had been looking to contribute that code to FlinkML, at which point I found him and alerted him to Beam. He has been learning a bit on Beam recently. Would this data-preprocessing be a welcome contribution to the project. If yes, perhaps others better versed in internals (I'm not there yet -- though could follow along!) would be willing to provide feedback to shape this to be a suitable Beam contribution. Cheers, Austin