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
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
