Package nz.org.riskscape.engine.task
package nz.org.riskscape.engine.task
-
ClassDescriptionGroups together pipeline steps that can be processed in the same task.The main interface for passing buffers of Tuples see core/ nz.org.riskscape.engine.Tuple between
WorkerTasks.Reads tuples from a buffer 'page'.Takes a page of tuples as input and writes smaller pages as output.Writes tuples to a buffer 'page'.Buffer that aWorkerTaskreads output from.The TaskSpec defines the work for a step or series of steps in a pipeline.A WorkerTask is based off a TaskSpec and is what actually carries out the work for the pipeline step(s).Buffer that aWorkerTaskwrites output to.