bigqueryoperator 是 write_truncate 1 个事务或 2 个事务
bigqueryoperator is write_truncate 1 transaction or 2 transactions
我希望在单笔交易中更换 table。我将 bigqueryoperator 与 write_disposition='WRITE_TRUNCATE' 一起使用，而我的 sql 只是 select * from my_table。我想知道这是否会发生在单个交易或两个单独的交易中？如果是 2 个事务，我是否可以在单个事务中用 select * from my_table 替换我的 bigquery table？
Airflow 使用作业 API 提交查询。 BigQuery documentation 提及 createDisposition 和 writeDisposition
Each action is atomic and only occurs if BigQuery is able to complete the job successfully. Creation, truncation and append actions occur as one atomic update upon job completion.
旁注 BigQueryOperator 已弃用。你应该使用 BigQueryExecuteQueryOperator
我希望在单笔交易中更换 table。我将 bigqueryoperator 与 write_disposition='WRITE_TRUNCATE' 一起使用，而我的 sql 只是 select * from my_table。我想知道这是否会发生在单个交易或两个单独的交易中？如果是 2 个事务，我是否可以在单个事务中用 select * from my_table 替换我的 bigquery table？
Airflow 使用作业 API 提交查询。 BigQuery documentation 提及 createDisposition 和 writeDisposition
Each action is atomic and only occurs if BigQuery is able to complete the job successfully. Creation, truncation and append actions occur as one atomic update upon job completion.
旁注 BigQueryOperator 已弃用。你应该使用 BigQueryExecuteQueryOperator