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	Wraps a CompletableFuture for jobs queued up on the Scheduler, mostly for historic reasons.
LinkedListBuffer
LopsidedJoinAdapter<T>	Wraps a LopsidedJoiner to present its methods as a Sink and a FlatProjector so that we don't need custom WorkerTask implementations to execute them in a pipeline.
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
TaskBuilderAssertionError	Throw by the TaskBuilder when the pipeline isn't as expected and so can not be converted in to tasks to run on the scheduler
Worker	The Worker represents a thread that can run tasks.