Alternatives to Apache Beam logo

Alternatives to Apache Beam

Apache Spark, Kafka Streams, Kafka, Airflow, and Google Cloud Dataflow are the most popular alternatives and competitors to Apache Beam.
138
261
+ 1
14

What is Apache Beam and what are its top alternatives?

It implements batch and streaming data processing jobs that run on any execution engine. It executes pipelines on multiple execution environments.
Apache Beam is a tool in the Workflow Manager category of a tech stack.

Top Alternatives to Apache Beam

  • Apache Spark

    Apache Spark

    Spark is a fast and general processing engine compatible with Hadoop data. It can run in Hadoop clusters through YARN or Spark's standalone mode, and it can process data in HDFS, HBase, Cassandra, Hive, and any Hadoop InputFormat. It is designed to perform both batch processing (similar to MapReduce) and new workloads like streaming, interactive queries, and machine learning. ...

  • Kafka Streams

    Kafka Streams

    It is a client library for building applications and microservices, where the input and output data are stored in Kafka clusters. It combines the simplicity of writing and deploying standard Java and Scala applications on the client side with the benefits of Kafka's server-side cluster technology. ...

  • Kafka

    Kafka

    Kafka is a distributed, partitioned, replicated commit log service. It provides the functionality of a messaging system, but with a unique design. ...

  • Airflow

    Airflow

    Use Airflow to author workflows as directed acyclic graphs (DAGs) of tasks. The Airflow scheduler executes your tasks on an array of workers while following the specified dependencies. Rich command lines utilities makes performing complex surgeries on DAGs a snap. The rich user interface makes it easy to visualize pipelines running in production, monitor progress and troubleshoot issues when needed. ...

  • Google Cloud Dataflow

    Google Cloud Dataflow

    Google Cloud Dataflow is a unified programming model and a managed service for developing and executing a wide range of data processing patterns including ETL, batch computation, and continuous computation. Cloud Dataflow frees you from operational tasks like resource management and performance optimization. ...

  • Apache Flink

    Apache Flink

    Apache Flink is an open source system for fast and versatile data analytics in clusters. Flink supports batch and streaming analytics, in one system. Analytical programs can be written in concise and elegant APIs in Java and Scala. ...

  • AWS Glue

    AWS Glue

    A fully managed extract, transform, and load (ETL) service that makes it easy for customers to prepare and load their data for analytics. ...

  • StreamSets

    StreamSets

    The industry's first data operations platform for full life-cycle management of data in motion. ...

Apache Beam alternatives & related posts

Apache Spark logo

Apache Spark

2.2K
2.6K
132
Fast and general engine for large-scale data processing
2.2K
2.6K
+ 1
132
PROS OF APACHE SPARK
  • 58
    Open-source
  • 48
    Fast and Flexible
  • 7
    One platform for every big data problem
  • 6
    Easy to install and to use
  • 6
    Great for distributed SQL like applications
  • 3
    Works well for most Datascience usecases
  • 2
    Machine learning libratimery, Streaming in real
  • 2
    In memory Computation
  • 0
    Interactive Query
CONS OF APACHE SPARK
  • 3
    Speed

related Apache Spark posts

Eric Colson
Chief Algorithms Officer at Stitch Fix | 21 upvotes 路 1.8M views

The algorithms and data infrastructure at Stitch Fix is housed in #AWS. Data acquisition is split between events flowing through Kafka, and periodic snapshots of PostgreSQL DBs. We store data in an Amazon S3 based data warehouse. Apache Spark on Yarn is our tool of choice for data movement and #ETL. Because our storage layer (s3) is decoupled from our processing layer, we are able to scale our compute environment very elastically. We have several semi-permanent, autoscaling Yarn clusters running to serve our data processing needs. While the bulk of our compute infrastructure is dedicated to algorithmic processing, we also implemented Presto for adhoc queries and dashboards.

Beyond data movement and ETL, most #ML centric jobs (e.g. model training and execution) run in a similarly elastic environment as containers running Python and R code on Amazon EC2 Container Service clusters. The execution of batch jobs on top of ECS is managed by Flotilla, a service we built in house and open sourced (see https://github.com/stitchfix/flotilla-os).

At Stitch Fix, algorithmic integrations are pervasive across the business. We have dozens of data products actively integrated systems. That requires serving layer that is robust, agile, flexible, and allows for self-service. Models produced on Flotilla are packaged for deployment in production using Khan, another framework we've developed internally. Khan provides our data scientists the ability to quickly productionize those models they've developed with open source frameworks in Python 3 (e.g. PyTorch, sklearn), by automatically packaging them as Docker containers and deploying to Amazon ECS. This provides our data scientist a one-click method of getting from their algorithms to production. We then integrate those deployments into a service mesh, which allows us to A/B test various implementations in our product.

For more info:

#DataScience #DataStack #Data

See more
Conor Myhrvold
Tech Brand Mgr, Office of CTO at Uber | 7 upvotes 路 938.5K views

Why we built Marmaray, an open source generic data ingestion and dispersal framework and library for Apache Hadoop :

Built and designed by our Hadoop Platform team, Marmaray is a plug-in-based framework built on top of the Hadoop ecosystem. Users can add support to ingest data from any source and disperse to any sink leveraging the use of Apache Spark . The name, Marmaray, comes from a tunnel in Turkey connecting Europe and Asia. Similarly, we envisioned Marmaray within Uber as a pipeline connecting data from any source to any sink depending on customer preference:

https://eng.uber.com/marmaray-hadoop-ingestion-open-source/

(Direct GitHub repo: https://github.com/uber/marmaray Kafka Kafka Manager )

See more
Kafka Streams logo

Kafka Streams

256
334
0
A client library for building applications and microservices
256
334
+ 1
0
PROS OF KAFKA STREAMS
    Be the first to leave a pro
    CONS OF KAFKA STREAMS
      Be the first to leave a con

      related Kafka Streams posts

      Kafka logo

      Kafka

      13.9K
      13K
      557
      Distributed, fault tolerant, high throughput pub-sub messaging system
      13.9K
      13K
      + 1
      557
      PROS OF KAFKA
      • 119
        High-throughput
      • 113
        Distributed
      • 85
        Scalable
      • 78
        High-Performance
      • 64
        Durable
      • 35
        Publish-Subscribe
      • 17
        Simple-to-use
      • 14
        Open source
      • 10
        Written in Scala and java. Runs on JVM
      • 6
        Message broker + Streaming system
      • 4
        Avro schema integration
      • 2
        Suport Multiple clients
      • 2
        Robust
      • 2
        KSQL
      • 2
        Partioned, replayable log
      • 1
        Fun
      • 1
        Extremely good parallelism constructs
      • 1
        Simple publisher / multi-subscriber model
      • 1
        Flexible
      CONS OF KAFKA
      • 27
        Non-Java clients are second-class citizens
      • 26
        Needs Zookeeper
      • 7
        Operational difficulties
      • 2
        Terrible Packaging

      related Kafka posts

      Eric Colson
      Chief Algorithms Officer at Stitch Fix | 21 upvotes 路 1.8M views

      The algorithms and data infrastructure at Stitch Fix is housed in #AWS. Data acquisition is split between events flowing through Kafka, and periodic snapshots of PostgreSQL DBs. We store data in an Amazon S3 based data warehouse. Apache Spark on Yarn is our tool of choice for data movement and #ETL. Because our storage layer (s3) is decoupled from our processing layer, we are able to scale our compute environment very elastically. We have several semi-permanent, autoscaling Yarn clusters running to serve our data processing needs. While the bulk of our compute infrastructure is dedicated to algorithmic processing, we also implemented Presto for adhoc queries and dashboards.

      Beyond data movement and ETL, most #ML centric jobs (e.g. model training and execution) run in a similarly elastic environment as containers running Python and R code on Amazon EC2 Container Service clusters. The execution of batch jobs on top of ECS is managed by Flotilla, a service we built in house and open sourced (see https://github.com/stitchfix/flotilla-os).

      At Stitch Fix, algorithmic integrations are pervasive across the business. We have dozens of data products actively integrated systems. That requires serving layer that is robust, agile, flexible, and allows for self-service. Models produced on Flotilla are packaged for deployment in production using Khan, another framework we've developed internally. Khan provides our data scientists the ability to quickly productionize those models they've developed with open source frameworks in Python 3 (e.g. PyTorch, sklearn), by automatically packaging them as Docker containers and deploying to Amazon ECS. This provides our data scientist a one-click method of getting from their algorithms to production. We then integrate those deployments into a service mesh, which allows us to A/B test various implementations in our product.

      For more info:

      #DataScience #DataStack #Data

      See more
      John Kodumal

      As we've evolved or added additional infrastructure to our stack, we've biased towards managed services. Most new backing stores are Amazon RDS instances now. We do use self-managed PostgreSQL with TimescaleDB for time-series data鈥攖his is made HA with the use of Patroni and Consul.

      We also use managed Amazon ElastiCache instances instead of spinning up Amazon EC2 instances to run Redis workloads, as well as shifting to Amazon Kinesis instead of Kafka.

      See more
      Airflow logo

      Airflow

      1.1K
      1.8K
      107
      A platform to programmaticaly author, schedule and monitor data pipelines, by Airbnb
      1.1K
      1.8K
      + 1
      107
      PROS OF AIRFLOW
      • 42
        Features
      • 13
        Task Dependency Management
      • 12
        Beautiful UI
      • 10
        Cluster of workers
      • 9
        Extensibility
      • 5
        Open source
      • 4
        Complex workflows
      • 4
        Python
      • 2
        Custom operators
      • 2
        K
      • 2
        Dashboard
      • 1
        Good api
      • 1
        Apache project
      CONS OF AIRFLOW
        Be the first to leave a con

        related Airflow posts

        Shared insights
        on
        Jenkins
        Airflow

        I am looking for an open-source scheduler tool with cross-functional application dependencies. Some of the tasks I am looking to schedule are as follows:

        1. Trigger Matillion ETL loads
        2. Trigger Attunity Replication tasks that have downstream ETL loads
        3. Trigger Golden gate Replication Tasks
        4. Shell scripts, wrappers, file watchers
        5. Event-driven schedules

        I have used Airflow in the past, and I know we need to create DAGs for each pipeline. I am not familiar with Jenkins, but I know it works with configuration without much underlying code. I want to evaluate both and appreciate any advise

        See more
        Shared insights
        on
        AWS Step Functions
        Airflow

        I am working on a project that grabs a set of input data from AWS S3, pre-processes and divvies it up, spins up 10K batch containers to process the divvied data in parallel on AWS Batch, post-aggregates the data, and pushes it to S3.

        I already have software patterns from other projects for Airflow + Batch but have not dealt with the scaling factors of 10k parallel tasks. Airflow is nice since I can look at which tasks failed and retry a task after debugging. But dealing with that many tasks on one Airflow EC2 instance seems like a barrier. Another option would be to have one task that kicks off the 10k containers and monitors it from there.

        I have no experience with AWS Step Functions but have heard it's AWS's Airflow. There looks to be plenty of patterns online for Step Functions + Batch. Do Step Functions seem like a good path to check out for my use case? Do you get the same insights on failing jobs / ability to retry tasks as you do with Airflow?

        See more
        Google Cloud Dataflow logo

        Google Cloud Dataflow

        165
        298
        3
        A fully-managed cloud service and programming model for batch and streaming big data processing.
        165
        298
        + 1
        3
        PROS OF GOOGLE CLOUD DATAFLOW
        • 1
          Unified batch and stream processing
        • 1
          Autoscaling
        • 1
          Fully managed
        CONS OF GOOGLE CLOUD DATAFLOW
          Be the first to leave a con

          related Google Cloud Dataflow posts

          Apache Flink logo

          Apache Flink

          378
          573
          35
          Fast and reliable large-scale data processing engine
          378
          573
          + 1
          35
          PROS OF APACHE FLINK
          • 15
            Unified batch and stream processing
          • 8
            Out-of-the box connector to kinesis,s3,hdfs
          • 8
            Easy to use streaming apis
          • 3
            Open Source
          • 1
            Low latency
          CONS OF APACHE FLINK
            Be the first to leave a con

            related Apache Flink posts

            Surabhi Bhawsar
            Technical Architect at Pepcus | 7 upvotes 路 509.6K views
            Shared insights
            on
            Kafka
            Apache Flink

            I need to build the Alert & Notification framework with the use of a scheduled program. We will analyze the events from the database table and filter events that are falling under a day timespan and send these event messages over email. Currently, we are using Kafka Pub/Sub for messaging. The customer wants us to move on Apache Flink, I am trying to understand how Apache Flink could be fit better for us.

            See more

            I have to build a data processing application with an Apache Beam stack and Apache Flink runner on an Amazon EMR cluster. I saw some instability with the process and EMR clusters that keep going down. Here, the Apache Beam application gets inputs from Kafka and sends the accumulative data streams to another Kafka topic. Any advice on how to make the process more stable?

            See more
            AWS Glue logo

            AWS Glue

            259
            478
            5
            Fully managed extract, transform, and load (ETL) service
            259
            478
            + 1
            5
            PROS OF AWS GLUE
            • 5
              Managed Hive Metastore
            CONS OF AWS GLUE
              Be the first to leave a con

              related AWS Glue posts

              Pardha Saradhi
              Technical Lead at Incred Financial Solutions | 6 upvotes 路 21.5K views

              Hi,

              We are currently storing the data in Amazon S3 using Apache Parquet format. We are using Presto to query the data from S3 and catalog it using AWS Glue catalog. We have Metabase sitting on top of Presto, where our reports are present. Currently, Presto is becoming too costly for us, and we are looking for alternatives for it but want to use the remaining setup (S3, Metabase) as much as possible. Please suggest alternative approaches.

              See more
              Punith Ganadinni
              Senior Product Engineer | 2 upvotes 路 14.9K views

              Hey all, I need some suggestions in creating a replica of our RDS DB for reporting and analytical purposes. Cost is a major factor. I was thinking of using AWS Glue to move data from Amazon RDS to Amazon S3 and use Amazon Athena to run queries on it. Any other suggestions would be appreciable.

              See more
              StreamSets logo

              StreamSets

              34
              76
              0
              Where DevOps Meets Data Integration
              34
              76
              + 1
              0
              PROS OF STREAMSETS
                Be the first to leave a pro
                CONS OF STREAMSETS
                • 2
                  No user community
                • 1
                  Crashes

                related StreamSets posts