Skip to content

delphamk/stream-processing-examples

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

18 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

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.

About

Apache Spark and Apache Flink examples

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

 
 
 

Contributors