-
Notifications
You must be signed in to change notification settings - Fork 513
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Relax avro record type bound #4803
Conversation
Object obj = value; | ||
for (Method getter : getOrInitGetters(keyPath, value.getClass())) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This was wrong. We would return the 1st cached getter regardless if the key was the primary or the secondary
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yikes!
@JsonIgnore private final AtomicReference<int[]> keyPath = new AtomicReference<>(); | ||
@JsonIgnore private final AtomicReference<int[]> keyPathSecondary = new AtomicReference<>(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We now have to delay the construction for those, as the schema is required to get access to the field index instead of the field name
Codecov Report
@@ Coverage Diff @@
## main #4803 +/- ##
==========================================
+ Coverage 60.67% 62.40% +1.72%
==========================================
Files 286 280 -6
Lines 10447 10405 -42
Branches 693 768 +75
==========================================
+ Hits 6339 6493 +154
+ Misses 4108 3912 -196
|
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroUtils.java
Show resolved
Hide resolved
7ec2884
to
3d4b7ad
Compare
17946a6
to
3d4b7ad
Compare
Part of #4459
Also fixes a bug for 2nd key in parquet for scala model