search

collectivemedia / celos

Scriptable scheduler for periodical Hadoop workflows
Apache License 2.0
22 stars 9 forks source link

Find dependent slots of a slot #637

Open manuel opened 8 years ago

manuel commented 8 years ago

Find the the downstream slots that depend on a slot.

This is trickier than just keeping a reverse mapping of workflows for each success trigger: we also need to take into account offsetTriggers! First step should be a method Set<SlotID> Scheduler.findDependentSlots(SlotID id)