Function mz_fivetran_destination::destination::dml::replace_files

async fn replace_files(
    database: &str,
    schema: &str,
    table: &Table,
    file_config: &FileConfig,
    client: &Client,
    replace_files: &[String]
) -> Result<(), OpError>

DELETE and then INSERT for all of the records in replace_files based on primary key.

TODO(benesch): the DELETE and INSERT are not issued transactionally, so they present as a retraction at one timestamp followed by an insertion at another, rather than presenting as a single update at a single timestamp.