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)[source]

基類: airflow.hooks.base.BaseHook, airflow.utils.log.logging_mixin.LoggingMixin

用於 Spark Connect 的 Hook。

PARAM_USE_SSL = 'use_ssl'[source]
PARAM_TOKEN = 'token'[source]
PARAM_USER_ID = 'user_id'[source]
conn_name_attr = 'conn_id'[source]
default_conn_name = 'spark_connect_default'[source]
conn_type = 'spark_connect'[source]
hook_name = 'Spark Connect'[source]
classmethod get_ui_field_behaviour()[source]

返回 Spark Connect 連線的自定義 UI 欄位行為。

classmethod get_connection_form_widgets()[source]

返回要新增到 Spark Connect 連線表單的連線元件。

get_connection_url()[source]

此條目有幫助嗎?