airflow.providers.apache.hive.transfers.hive_to_samba

此模块包含一个操作符，用于将数据从 Hive 移动到 Samba。

模块内容

类

HiveToSambaOperator

在特定的 Hive 数据库中执行 hql 代码，并将结果作为 csv 加载到 Samba 位置。
class airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator(*, hql, destination_filepath, samba_conn_id='samba_default', hiveserver2_conn_id='hiveserver2_default', **kwargs)[source]

基类: airflow.models.BaseOperator

在特定的 Hive 数据库中执行 hql 代码，并将结果作为 csv 加载到 Samba 位置。

参数

  • hql (str) – 要导出的 hql。（已模板化）

  • destination_filepath (str) – 文件将推送到 samba 的文件路径

  • samba_conn_id (str) – 对 samba 目标的引用

  • hiveserver2_conn_id (str) – 对 :ref: Hive Server2 thrift 服务连接 id <howto/connection:hiveserver2> 的引用。

template_fields: collections.abc.Sequence[str] = ('hql', 'destination_filepath')[source]
template_ext: collections.abc.Sequence[str] = ('.hql', '.sql')[source]
template_fields_renderers[source]
execute(context)[source]

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

此条目是否有帮助？