tfx.orchestration.beam.beam_dag_runner.BeamDagRunner

Class `BeamDagRunner`

Tfx runner on Beam.

Inherits From: TfxRunner

__init__(beam_orchestrator_args=None)

Initializes BeamDagRunner as a TFX orchestrator.

beam_orchestrator_args: beam args for the beam orchestrator. Note that this is different from the beam_pipeline_args within additional_pipeline_args, which is for beam pipelines in components.

run(tfx_pipeline)

Deploys given logical pipeline on Beam.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.