Join the SIG TFX-Addons community and help make TFX even better!

Module: tfx.orchestration.beam.beam_dag_runner

Definition of Beam TFX runner.

Classes

class BeamDagRunner: Tfx runner on Beam.

class PipelineNodeAsDoFn: Wrap node as beam DoFn.