Open gergely-g opened 2 weeks ago
Part of the solution could be in avro_value_to_beam_value()
Checking for the beam_type
matching this FieldType:
logical_type {
urn: "beam:logical_type:millis_instant:v1"
representation {
atomic_type: INT64
}
}
The converter could return Timestamp.of
to convert from datetime.datetime
.take-issue
.take-issue
What happened?
When importing Avro files that have schemas with the field type:
an attempt to convert the collection to Beam Schemas (beam.Row) will fail with a
TypeError
inRowCoderImpl
in the form:Avro files with
timestamp-millis
logical types are created for example when a BigQuery table data with column typeTIMESTAMP
gets exported to.avro
files.Unit test to repro the issue:
Issue Priority
Priority: 2 (default / most bugs should be filed as P2)
Issue Components