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

模組內容¶

Qubole 檢查 Hook。

airflow.providers.qubole.hooks.qubole_check.isint(value)[原始碼]¶

判斷 Qubole 欄位是否為整數。

airflow.providers.qubole.hooks.qubole_check.isfloat(value)[原始碼]¶

判斷 Qubole 欄位是否為浮點數。

airflow.providers.qubole.hooks.qubole_check.isbool(value)[原始碼]¶

判斷 Qubole 欄位是否為布林值。

airflow.providers.qubole.hooks.qubole_check.parse_first_row(row_list)[原始碼]¶

解析 Qubole 第一筆記錄列表。

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

Qubole 檢查 Hook。

static handle_failure_retry(context)[原始碼]¶

處理失敗時的重試。

get_query_results()[原始碼]¶

取得 Qubole 查詢結果。