This applies to sources and cannot be used inside the Pipeline.
Essentially, what would be needed is a support for a back edge from a
PTransform to source(s) to notify the source PTransform(s) to terminate.
This is also essential for any possible support for iterations (which
would probably be
I'm attempting to do the following in my DoFn to extract a double value
from an existing nullable field in my schema: *@FieldAccess("field1) Double
field*. However I'm getting the following exception:
*java.lang.IllegalArgumentException: Element argument type java.lang.Double
does not work with ex
