ingest_funcs

Module Contents

Functions

ingest_cdc_pg(backend, db, connector, table_list, domain)

ingest_funcs.ingest_cdc_pg(backend, db, connector, table_list, domain)

Parameters

• backend (easy_sql.sql_processor.backend.FlinkBackend) –

• db (str) –

• connector (str) –

• table_list (str) –

• domain (str) –