diff --git a/airflow/hooks/dbapi_hook.py b/airflow/hooks/dbapi_hook.py index 11957ffe2df4f..e5de92e6e59f7 100644 --- a/airflow/hooks/dbapi_hook.py +++ b/airflow/hooks/dbapi_hook.py @@ -203,6 +203,17 @@ def _serialize_cell(cell): else: return str(cell) + def bulk_dump(self, table, tmp_file): + """ + Dumps a database table into a tab-delimited file + + :param table: The name of the source table + :type table: str + :param tmp_file: The path of the target file + :type tmp_file: str + """ + raise NotImplementedError() + def bulk_load(self, table, tmp_file): """ Loads a tab-delimited file into a database table