Удалить большую таблицу запросов, используя Apache Beam java
Можно ли удалить таблицу, доступную в bigQuery, используя Apache Beam, используя Java?
p.apply("Delete Table name", BigQueryIO.readTableRows().fromQuery("DELETE FROM Table_name where condition"));
3 ответа
Я решил это с помощью BQ API.
BigQuery bigquery = BigQueryOptions.newBuilder(). SetCredentials (учетные данные).setProjectId (Имя проекта).build (). GetService (); QueryJobConfiguration queryConfig = QueryJobConfiguration.newBuilder(Query).setUseLegacySql (false).build (); JobId jobId = JobId.of (UUID.randomUUID (). ToString()); Задание queryJob = bigquery.create(JobInfo.newBuilder(queryConfig).setJobId(jobId).build());