Package nz.org.riskscape.engine.sched

package nz.org.riskscape.engine.sched

Related Packages

Package	Description
nz.org.riskscape.engine

Class	Description
AccumulatorSink	An unbounded Sink that receives results for accumulation, intended for use at the end of a ChainTask where a chain can feed multiple groupings, or, in a standalone SinkTask where usually (so far) a single collection is fed from something other than a chain - perhaps another grouping.
AccumulatorSink.Constructor
CombinedPageBuffer	Combines multiple ReadPageBuffers into one, for convenience
ExecutionFuture	Used as a Future for jobs queued up on the Scheduler.
LinkedListBuffer
Page	The Scheduler works with Pages, which is simply a block of Tuples.
PageAllocator	Handles all the complicated logic of how many tuples should fit into a Page.
Scheduler	The Scheduler oversees the execution of the pipeline tasks.
Scheduler.LocalProblems
SchedulerBasedExecutor	Executes a pipeline by breaking the steps down into tasks, and then using a Scheduler to manage running the tasks in parallel where possible.
TaskBuilder	Produces a set of TaskSpecs for execution on a Scheduler
Worker	The Worker represents a thread that can run tasks.