Is there a way to extend already defined PTransforms? My question is
probably better illustrated with an example. Let's say I have a PTransform
that generates a very variable number of outputs. I'd like to "wrap" that
PTransform such that if it ever creates more than say 1,000 outputs, then I
just take the first 1,000 outputs without generating the rest of the
outputs.

It'd be trivial if I have access to the DoFn, but what if the PTransform in
question doesn't expose the `DoFn`?

Reply via email to