[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