/apache-flink-101

Apache Flink 101

Primary LanguageJava

Flink program

  1. Makes a request to the swapi (https://swapi.co/) API and retrieves a list of star-ships.
  2. For every star-ship that has pilots, output the Ship Name and Pilot (gender, hair color, height, mass, name) to a CSV file.
  3. Final Result: Load all the films of selected pilots in elastic search.