[GitHub] [airflow] rolldeep commented on pull request #7126: [AIRFLOW-6405] Add GCP BigQuery Table Upsert Operator

[GitBox <gi...@apache.org>]

rolldeep commented on pull request #7126:
URL: https://github.com/apache/airflow/pull/7126#issuecomment-1058249946


   Hi @jithin-sukumar , thanks for your operator!
   
   Unfortunately, I can't figure out how to use it. Currently I want to upsert delta table into main table. There is no parameters for the destination (main) table.
   
   Here is my operator:
   ```python
   upsert_table = BigQueryUpsertTableOperator(
                   task_id=f"upsert_table",
                   dataset_id='DATASET_NAME',
                   table_resource={
                       "tableReference": {"tableId": f" {config.get('TABLE_NAME')}"},
                       "expirationTime": (int(time.time()) + 300) * 1000,
                   },
               )
   ```
   The problem is that I can't choose the destination (main) table. @jithin-sukumar can you explain how can I set up my destination table? As I see, current implementation uses tableReference for both source and destination. 


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org