[This is preliminary documentation and is subject to change.]
Data source from another graph manager.
Inheritance Hierarchy
Microsoft.Research.Naiad.InputBaseDataSourceTRecord
Microsoft.Research.Naiad.InputInterGraphDataSourceTRecord
Namespace: Microsoft.Research.Naiad.Input
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public class InterGraphDataSource<TRecord> : BaseDataSource<TRecord>
Type Parameters
- TRecord
- record type
The InterGraphDataSourceTRecord type exposes the following members.
Constructors
Name | Description | |
---|---|---|
InterGraphDataSourceTRecord |
Constructs a new InterGraphDataSource from the given InterGraphDataSink.
|
Methods
Name | Description | |
---|---|---|
Activate |
Registers itself with the InterGraphDataSink.
(Overrides BaseDataSourceTRecordActivate.) | |
Join |
Called by the Computation before it completes its own Join().
(Inherited from BaseDataSourceTRecord.) | |
OnCompleted |
Forwards a completion to the appropriate worker
| |
OnNotify |
Forwards a notification to the appropriate worker
| |
OnRecv |
Forwards a message to the appropriate worker
| |
RegisterInputs |
Registers StreamingInputs with the DataSource.
(Inherited from BaseDataSourceTRecord.) |
Fields
Name | Description | |
---|---|---|
inputsByWorker |
StreamingInputs corresponding to local workers.
(Inherited from BaseDataSourceTRecord.) |
See Also