leananeuber / akkaactorparty Goto Github PK

adopt Java-code from akka-tutorial to our needs:

• add akka-cluster dependencies
• create configuration file with reasonable default values
• configure logging
• terminate ActorSystems on disconnect from the cluster

Additional resources: Akka cluster example project

• Implement algorithm (see slides)
• Parallelize

• Decide upon algorithm and understand it
• Implement algorithm
• Parallelize if possible

Implement a CLI that conforms with the following requirements:

• provide three commands:
  • master starts the master-node, supports following arguments:
    • --workers number of local worker actors to start on the master node
    • --slaves number of slave actor systems to wait for (cluster is up, when all slaves have joined it)
    • --input path to the input CSV file
  • slave starts a slave node
    • --workers number of worker actors to start on the node
    • --host hostname of the master system
  • help prints help document
• example calls:

  > java -jar YourAlgorithmName.jar master --workers 4 --slaves 4 --input students.csv
  > java -jar YourAlgorithmName.jar slave --workers 4 --host 198.172.0.24

• master program terminal outputs: overall time and result CSV string

• Generate rainbow tables
• Implement LookUp query
• Decide upon data handling

Implement the Reaper-pattern for controlled shutdown of all actor systems after work is done.

Initialization:

• we need one Reaper actor per actor system
• all actors of this system must register themselves at the Reaper
• Reaper listens for Terminated messages

Controlled shutdown:

1. master sends PoisonPill to all known actors
2. all actors forward PoisonPill to their childs
3. Reaper receives Terminated messages
4. After no more ActorRefs are in the Reaper's state, it terminates his actor system: context.system.terminate()

• Decide upon algorithm and understand it
• Implement algorithm
• Parallelize if possible

#10 is missing the master program terminal outputs requested in #8. We should add them after implementing the processing logic.