基类: 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]