From 1b60a81be5fa7795c8e8d4873a85bf5ca2211503 Mon Sep 17 00:00:00 2001 From: Bence Nagy Date: Fri, 6 May 2016 15:54:04 +0200 Subject: [PATCH] Add bulk_dump abstract method to DbApiHook --- airflow/hooks/dbapi_hook.py | 11 +++++++++++ 1 file changed, 11 insertions(+) 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