Hi,

I want to be able to write a verification phase that asserts that input and
output schemas for all ParDos match up properly. The only place I can see
to do that today is in expand(), however this does not work as Coders may
not be fully known when expand is called (remember Schemas are implemented
as a special type of Coder today). For example:

p.apply(ParDo.of(MyDoFn))
  .SetCoder(FooCoder());

FooCoder is not known yet when expand is called for the ParDo.

Is there any place in Beam today where I could set up such a verification
pass?

Reuven

Reply via email to