使用scala从spark中删除bigquery表

1aaf6o9v 于 2021-05-27 发布在 Spark

关注(0)|答案(1)|浏览(371)

有没有办法使用scala从spark中删除bigquery表？
我只能通过使用以下示例中的scala从spark中读取和写入bigquery表：https://cloud.google.com/dataproc/docs/tutorials/bigquery-connector-spark-example
有人能举个例子来删除bigquery表吗？例如，我可以使用以下语句在bigquery控制台中删除一个表“ drop table if exists projectid1.dataset1.table1 ".
请注意，我删除现有表的目的不是覆盖。我只是想把它去掉。请帮忙。谢谢。

scala apache-spark google-bigquery

来源：https://stackoverflow.com/questions/62976181/delete-bigquery-table-from-spark-by-using-scala

1条答案

按热度按时间

cclgggtu1#

请参考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中工作。在另一个簇中，您需要正确设置主峰

赞(0）回复(0）举报 2021-05-27

我来回答

使用scala从spark中删除bigquery表

1条答案

相关问题

热门标签

最新问答