LocalPipeline

LocalPipeline定义

class bigflow.pipeline.local_pipeline.LocalPipeline(**job_config)

基类：bigflow.pipeline.pipeline_base.PipelineBase

在本地引擎单机执行的Pipeline

参数:**job_config — 一些引擎相关的参数

  • add_file(file_path, resource_path=None, executable=False)

    向Pipeline添加单个文件，使得该文件能够在运行期被访问

    参数:
    • file_path (str) — 需要添加的文件路径，可以是本地路径或者 HDFS 路径.
    • resource_path (str) — local 引擎运行时访问该文件的路径, 应是相对路径. 也即本地引擎在执行时, file_path 将会被映射到该 resource_path, 用户程序可以以该路径访问
    • executable (bool) — 若为True，则该文件在运行期会被添加可执行属性

  • run()

    立刻运行Pipeline并等待结束

    Raises:BigflowRuntimeException — 若运行期出错抛出此异常