easy_sql.utils.db_connection_utils

Module Contents

Functions

get_connector_raw_conn_for_flink_backend(backend, connector_name)

easy_sql.utils.db_connection_utils.get_connector_raw_conn_for_flink_backend(backend, connector_name)

Parameters

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

• connector_name (str) –

Return type

Optional[sqlalchemy.engine.base.Connection]