Apache Beam aims to provide a unified stream processing model along with a set of language-specific SDKs for defining and executing complex data processing, data ingestion and integration workflows. This will simplify how we implement and think about large-scale batch and streaming data processing. Pipelines can be run on Apache Flink, Apache Spark, and Google Cloud Dataflow with more to come.
{}