MCPcopy Create free account
hub / github.com/baidu/bigflow / create

Method create

bigflow_python/python/bigflow/base.py:71–116  ·  view source on GitHub ↗

根据用户所指定的后端引擎类型以及基本配置构造一个Pipeline实例 Args: pipeline_type (str): 指定Pipeline类型,目前支持``"local"``和``"hadoop"`` **job_config: Pipeline配置 hadoop模式: job_name: 用于指定Hadoop作业名 tmp_data_path: 用于指定保存运行包等信息的HDFS路径,请确保ugi有操作权限

(pipeline_type, **job_config)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

group_top_n.pyFile · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected