You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/07/16 12:24:51 UTC
incubator-airflow git commit: [AIRFLOW-2748] add new command args for
dbimport and dbexport command to qubole hook
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 <jo...@qubole.com>
Authored: Mon Jul 16 14:24:44 2018 +0200
Committer: Fokko Driesprong <fo...@godatadriven.com>
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']
}