使用 Apache Beam java 删除大查询 table
Delete Big query table using Apache Beam java
是否可以使用 Java 使用 Apache Beam 删除 bigQuery 中可用的 table？
p.apply("Delete Table name", BigQueryIO.readTableRows().fromQuery("DELETE FROM Table_name where condition"));
我使用 BQ API 解决了这个问题。
BigQuery bigquery = BigQueryOptions.newBuilder().setCredentials(credential).setProjectId(ProjectName).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());
是否可以使用 Java 使用 Apache Beam 删除 bigQuery 中可用的 table？
p.apply("Delete Table name", BigQueryIO.readTableRows().fromQuery("DELETE FROM Table_name where condition"));
我使用 BQ API 解决了这个问题。
BigQuery bigquery = BigQueryOptions.newBuilder().setCredentials(credential).setProjectId(ProjectName).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());