`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(self)[source]¶

Get Qubole query result