Can you explain a bit how SchemadParDo works?

On Fri, May 9, 2025 at 4:49 PM Joey Tran <joey.t...@schrodinger.com> wrote:

> I've written a `SchemadParDo(input_field: str, output_field, dofn:DoFn)`
> transform for more easily writing a Schemad transform given a DoFn.
>
> Is this something worth upstreaming into the Beam Python SDK? I wrote it
> to make it easier to convert our current set of dofn's into schemad dofns
> for use with the YAML SDK. Just wanted to gauge interest before setting up
> the dev env again
>

Reply via email to