`airflow.providers.apache.spark.hooks.spark_connect`¶

模組內容¶

類別¶

SparkConnectHook

Spark Connect 的 Hook。

class airflow.providers.apache.spark.hooks.spark_connect.SparkConnectHook(conn_id=default_conn_name)[原始碼]¶

繼承自: airflow.hooks.base.BaseHook, airflow.utils.log.logging_mixin.LoggingMixin

Spark Connect 的 Hook。

PARAM_USE_SSL = 'use_ssl'[原始碼]¶

PARAM_TOKEN = 'token'[原始碼]¶

PARAM_USER_ID = 'user_id'[原始碼]¶

conn_name_attr = 'conn_id'[原始碼]¶

default_conn_name = 'spark_connect_default'[原始碼]¶

conn_type = 'spark_connect'[原始碼]¶

hook_name = 'Spark Connect'[原始碼]¶

classmethod get_ui_field_behaviour()[原始碼]¶

傳回 Spark Connect 連線的自訂 UI 欄位行為。

classmethod get_connection_form_widgets()[原始碼]¶

傳回要新增至 Spark Connect 連線表單的連線小工具。

get_connection_url()[原始碼]¶

這個條目是否有幫助？