Package nz.org.riskscape.engine.sched
package nz.org.riskscape.engine.sched
-
ClassDescriptionCombines multiple ReadPageBuffers into one, for convenienceUsed as a
Futurefor jobs queued up on the Scheduler.TheSchedulerworks with Pages, which is simply a block of Tuples.Handles all the complicated logic of how many tuples should fit into a Page.The Scheduler oversees the execution of the pipeline tasks.Executes a pipeline by breaking the steps down into tasks, and then using a Scheduler to manage running the tasks in parallel where possible.The Worker represents a thread that can run tasks.