[This is preliminary documentation and is subject to change.]
Interface specifying the behavior of a coordinator vertex. A coordinator takes a stream of input records via calls to AddInput,
and for each input it generates a set of work items. As workers become free, the coordinator is informed, via AssignWork, and
responds with a work item for that worker, or nothing if there is no more work for that worker to perform.
Namespace: Microsoft.Research.Naiad.Frameworks.WorkGenerator
Assembly: Microsoft.Research.Naiad.WorkGenerator (in Microsoft.Research.Naiad.WorkGenerator.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public interface ICoordinator<TInput, TWorkDescription, TWorkerDescription>
Type Parameters
- TInput
- Type of the input records
- TWorkDescription
- Type of the description of an individual work item
- TWorkerDescription
- Type of the description of a worker, used to match items to workers
The ICoordinatorTInput, TWorkDescription, TWorkerDescription type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
 | AddInput |
Take an input record, translate it to a set of work items, and add those items to an internal datastructure of
outstanding work.
|
| AssignWork |
Given a worker that is now free, optionally assign it a work item. If no work item is assigned for that worker, the
worker will never be presented in a subsequent call to AssignWork, i.e. it is assumed that there is no more work for
that worker.
|
See Also