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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
