I am beginner in airbyte and have set up env in local and trying to create a custom destination(postgres) in python. spec and check fuction is created and is running fine. Just a question, how queries will be written in write function (main workhouse of destination connector) so it can recieve data from source and write in destination in new table. Should i have to use sql queries or what means how basically it communicates with source data and writes in destination datbase.
Please help me in this. Thanks in advance