[This is preliminary documentation and is subject to change.]
Represents an abstract stage in a dataflow graph, which comprises one or more dataflow vertices that each
handle a partition of the data received by the stage, with a time type that
indicates its level of nesting in the graph.
Inheritance Hierarchy
Microsoft.Research.Naiad.DataflowStage
Microsoft.Research.Naiad.DataflowStageTTime
Microsoft.Research.Naiad.DataflowStageTVertex, TTime
Namespace: Microsoft.Research.Naiad.Dataflow
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public abstract class Stage<TTime> : Stage where TTime : Object, Time<TTime>
Type Parameters
- TTime
- The type of timestamps on messages that this stage processes.
The StageTTime type exposes the following members.
Methods
Name | Description | |
---|---|---|
NewInputTRecord, TTime(StreamTRecord, TTime, ExpressionFuncTRecord, Int32) |
Creates a new input for this stage, with the given partitioning requirement.
(Inherited from Stage.) | |
NewInputTRecord, TTime(StreamTRecord, TTime, ExpressionFuncTRecord, Int32, ActionTRecord, Int32, Int32) |
Creates a new input for this stage, with the given partitioning requirement.
(Inherited from Stage.) | |
ToString |
Returns the stage name decorated with the stage ID.
(Inherited from Stage.) |
Fields
Name | Description | |
---|---|---|
Placement |
the placement used for the stage
(Inherited from Stage.) | |
StageId |
the unique identifier associated with the stage
(Inherited from Stage.) |
Properties
Name | Description | |
---|---|---|
Computation |
the graph manager associated with the stage
(Inherited from Stage.) | |
Context |
The time context (e.g. loop body) to which this stage belongs.
| |
Name |
Returns the stage name undecorated by stage id
(Inherited from Stage.) |
Remarks
See Also