Modifies Table API `AvroSchemaConvertor` implementation.

GoogleCloudDataproc / flink-bigquery-connector

BigQuery integration to Apache Flink's Table API

Apache License 2.0

15 stars 11 forks source link

Closed prashastia closed 3 months ago

prashastia commented 3 months ago

Adds implementation for AvroSchemaConvertor responsible for:
- Convert Avro Schema to DataType schema and vice versa
Also adds tests for the same.
Test for BigQueryTableSchemaProvider to test the conversion of Avro Schema -> Data Type Schema (via invocation of AvroSchemaConvertor
Modifies AvroToRowDataConvertor to modify certain datatypes for the connector (to facilitate read)

/gcbrun

prashastia commented 3 months ago

@clmccart requesting your review on this PR. Thanks!

jayehwhyehentee commented 3 months ago

@clmccart @yerramalli requesting your reviews