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

模块内容¶

Qubole 检查钩子。

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

判断 Qubole 列是否为整数。

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

判断 Qubole 列是否为浮点数。

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

判断 Qubole 列是否为布尔值。

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

解析 Qubole 第一条记录列表。

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

Qubole 检查钩子。

static handle_failure_retry(context)[source]¶

处理失败时的重试。

get_query_results()[source]¶

获取 Qubole 查询结果。