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?