BeamHook
Apache BeamHook for Apache Beam.
Access Instructions
Install the Apache Beam provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
runnerRunner type
Documentation
Hook for Apache Beam.
All the methods in the hook where project_id is used must be called with keyword arguments rather than positional.