@FieldAccess parameter types not being enforced vs corresponding schema types in Java DoFn

2023-09-18 Thread Varun Golani
I've been looking at the following session from the 2019 Beam Summit covering Schema-aware PCollections (18:00 - https://www.youtube.com/watch?v=aRIZXtQiCHw). The specific part of the video mentions that for fields accessed via the @FieldAccess annotation, Beam checks for both the existence of the

Unable to use Java Double in @FieldAccess for nullable DOUBLE schema field

2023-09-19 Thread Varun Golani
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