Repository: incubator-airflow Updated Branches: refs/heads/master 3dabd8f03 -> 17ddbcff0
[AIRFLOW-2748] add new command args for dbimport and dbexport command to qubole hook Closes #3597 from Joylal4896/master Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/17ddbcff Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/17ddbcff Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/17ddbcff Branch: refs/heads/master Commit: 17ddbcff0bef0c11aa4468513d645b6d2480d8f3 Parents: 3dabd8f Author: Joy Lal Chattaraj <[email protected]> Authored: Mon Jul 16 14:24:44 2018 +0200 Committer: Fokko Driesprong <[email protected]> Committed: Mon Jul 16 14:24:44 2018 +0200 ---------------------------------------------------------------------- airflow/contrib/hooks/qubole_hook.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/17ddbcff/airflow/contrib/hooks/qubole_hook.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/hooks/qubole_hook.py b/airflow/contrib/hooks/qubole_hook.py index fb45862..5be5923 100755 --- a/airflow/contrib/hooks/qubole_hook.py +++ b/airflow/contrib/hooks/qubole_hook.py @@ -66,10 +66,12 @@ COMMAND_ARGS = { 'user_program_arguments'], 'dbexportcmd': ['mode', 'hive_table', 'partition_spec', 'dbtap_id', 'db_table', 'db_update_mode', 'db_update_keys', 'export_dir', - 'fields_terminated_by', 'tags', 'name'], + 'fields_terminated_by', 'tags', 'name', 'customer_cluster_label', + 'use_customer_cluster', 'additional_options'], 'dbimportcmd': ['mode', 'hive_table', 'dbtap_id', 'db_table', 'where_clause', 'parallelism', 'extract_query', 'boundary_query', 'split_column', - 'tags', 'name'] + 'tags', 'name', 'hive_serde', 'customer_cluster_label', + 'use_customer_cluster', 'schema', 'additional_options'] }
