-
Notifications
You must be signed in to change notification settings - Fork 4.3k
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
[java] BQ: add missing avro conversions to BQ TableRow #33221
Conversation
Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment |
Avro float fields can be used to write BQ FLOAT columns. Add TableRow conversion for such field. Adding conversion for aveo 1.10+ logical types local-timestamp-millis and local-timestam-micros.
81a60b1
to
943b361
Compare
Follow-up: RustedBones#108 |
Assigning reviewers. If you would like to opt out of this review, comment R: @damondouglas for label java. Available commands:
The PR bot will only process comments in the main thread (not review comments). |
Reminder, please take a look at this pr: @damondouglas @johnjcasey |
...ogle-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java
Show resolved
Hide resolved
...-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java
Show resolved
Hide resolved
Thanks for the change! Just had two questions. |
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.
Thank you!
Fix #33197
Add missing
avro -> BQ
conversions:float
->INTEGER
time-millis
->TIME
timestamp-millis
->TIMESTAMP
local-timestamp-millis
->DATETIME
local-timestamp-micros
->DATETIME
enum
->STRING
fixed
->BYTES
map
->RECORD
key/valueReworked
BigQueryAvroUtilsTest
to test conversions in isolation.Ideally
BigQueryAvroUtils
should also provide a schema converteravro.Schema -> TableSchema
to facilitate write of avro model to BQ