Apache Beam

Certified

Tasks that run pipelines against SDKs and dedicated runners including Apache Flink

Execute Apache Beam pipelines defined in YAML on Direct, Flink, Spark, or Dataflow runners while forwarding Beam metrics to Kestra.