Hi all, I'm attempting to build a Table API connector for BigQuery using the BigQuery Storage API ( https://cloud.google.com/bigquery/docs/reference/storage).
I've got a base structure built out at https://github.com/mnbbrown/bigquery-connector There's a couple of things I have to do yet like correcting the mapping between the BigQuery avro schema and flink TypeInformation, and add a test suite. I've added it to an internal project I'm working on and "nextRecord" on the InputFormat is never called. I can see open/close, openInputFormat/closeInputFormat, etc being called correctly. Does anybody have any debugging tips? Thanks, Matt. -- -- AU: +61 459 493 730 UK: +44 7927 618921 @mnbbrown
