`airflow.contrib.hooks.qubole_check_hook`¶

Module Contents¶

airflow.contrib.hooks.qubole_check_hook.COL_DELIM =[source]¶

airflow.contrib.hooks.qubole_check_hook.ROW_DELIM =[source]¶

airflow.contrib.hooks.qubole_check_hook.isint(value)[source]¶

airflow.contrib.hooks.qubole_check_hook.isfloat(value)[source]¶

airflow.contrib.hooks.qubole_check_hook.isbool(value)[source]¶

airflow.contrib.hooks.qubole_check_hook.parse_first_row(row_list)[source]¶

class airflow.contrib.hooks.qubole_check_hook.QuboleCheckHook(context, *args, **kwargs)[source]¶

Bases: airflow.contrib.hooks.qubole_hook.QuboleHook

static handle_failure_retry(context)[source]¶

get_first(self, sql)[source]¶

get_query_results(self)[source]¶

Was this entry helpful?