`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()[源代码]¶

此条目是否有帮助？