Adds tests for `BigQueryReadTableConfig` and `BigQueryConnectorOptions`

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 tests for BigQueryConnectorOptions
- Uses the BigQueryReadTableConfig for formation of TableDescriptor and ReadOptions rather than Map.
- Consequently involves modification of StorageClientFaker to provide records via recordGenerator of the desired schema.
- Also mocks QueryDataClient. getTableSchema() to provide BigQuery Table Schema.
Also adds MODE (BOUNDED or UNBOUNDED) and PARTITION_DISCOVERY_INTERVAL as one of the connector options.

/gcbrun

prashastia commented 3 months ago

@clmccart Pls review this PR. Thanks!