`airflow.providers.qubole.hooks.qubole_check`¶

Module Contents¶

Qubole check hook.

`isint`(value)	Whether Qubole column are integer.
`isfloat`(value)	Whether Qubole column are float.
`isbool`(value)	Whether Qubole column are boolean.
`parse_first_row`(row_list)	Parse Qubole first record list.

airflow.providers.qubole.hooks.qubole_check.isint(value)[source]¶

Whether Qubole column are integer.

airflow.providers.qubole.hooks.qubole_check.isfloat(value)[source]¶

Whether Qubole column are float.

airflow.providers.qubole.hooks.qubole_check.isbool(value)[source]¶

Whether Qubole column are boolean.

airflow.providers.qubole.hooks.qubole_check.parse_first_row(row_list)[source]¶

Parse Qubole first record list.

class airflow.providers.qubole.hooks.qubole_check.QuboleCheckHook(context, *args, **kwargs)[source]¶

Qubole check hook.

static handle_failure_retry(context)[source]¶

Handle retries in case of failures.

get_query_results()[source]¶

Get Qubole query result.