使用 scala 从 spark 中删除 bigquery 表

Question

有没有办法使用 Scala 从 Spark 中删除 BigQuery 表？

我只找到了使用示例中的 Scala 从 Spark 读取和写入 BigQuery 表的方法： https://cloud.google.com/dataproc/docs/tutorials/bigquery-connector-spark-example

有人可以提供删除 BigQuery 表的示例吗？例如，我可以使用此语句“drop table if exists projectid1.dataset1.table1”在 BigQuery 控制台中删除一个表。

请注意，我删除现有表的目的不是覆盖。我只是想删除它。请帮忙。谢谢。

Answer 1

请参考BigQuery API：

import com.google.cloud.spark.bigquery.repackaged.com.google.cloud.bigquery.{BigQueryOptions, TableId}

val bq = BigQueryOptions.getDefaultInstance().getService() 
val table = bq.getTable(TableId.of("projectid1", "dataset1", "table1"))
if(table != null) {
  table.delete()
}

请注意，这应该可以在 Dataproc 中使用。在其他集群中，您需要正确设置凭证