我正在使用DataFlow v1.9使用以下代码检索BigQuery表的模式:

Bigquery bigQueryClient=Transport.newBigQueryClient(options.as(BigQueryOptions.class)).build();
Tables tableRequest = bigQueryClient.tables();
Table table = tableRequest.get("","","").execute();
List<TableFieldSchema> fieldss = table.getSchema().getFields();
TableSchema schemaa = table.getSchema();

但是,这在Apache Beam中不起作用 . 如何在apache Beam中做同样的事情?

我在Apache梁中编写相同的代码时收到以下消息:“方法newBigQueryClient(options.as(BigQueryOptions.class))未定义为类型Transport

谢谢