/stream-processing-examples

Apache Spark and Apache Flink examples

Primary LanguagePython

Setup Steps

  1. Run the following command to start the application within a Docker container: 
    docker-compose up --build app
  2. To view the word count aggregation in MongoDB for Apache Spark, open the following link: http://0.0.0.0:8081/db/mydatabase/word_count
  3. To view the aggregation for Apache Flink, run the file "DataStreamJob.java" as part of the Flink application.