Stage(TVertex, TTime) Class

StageTVertex, TTime Class

Naiad Help

[This is preliminary documentation and is subject to change.]

Represents a stage in a dataflow graph, which comprises one or more dataflow vertices of a particular type that each handle a partition of the data received by the stage.

Inheritance Hierarchy

SystemObject
  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

Copy

public class Stage<TVertex, TTime> : Stage<TTime>
where TVertex : Vertex<TTime>
where TTime : Object, Time<TTime>

Type Parameters

TVertex: The type of dataflow vertices in this stage.
TTime: The type of timestamps on messages that this stage processes.

The StageTVertex, TTime type exposes the following members.

Constructors

	Name	Description
	StageTVertex, TTime	Constructs a new stage in the given time context, using the given vertex factory to construct the constituent vertices.

Top

Methods

	Name	Description
	NewInputTRecord(StreamTRecord, TTime, ActionMessageTRecord, TTime, TVertex, ExpressionFuncTRecord, Int32)	Creates a new input that consumes records from the given stream, partitioned by the given partitioning function, and delivers them to a vertex through the given onReceive callback.
	NewInputTRecord(StreamTRecord, TTime, ActionMessageTRecord, TTime, TVertex, ExpressionFuncTRecord, Int32, ActionTRecord, Int32, Int32)	Creates a new input that consumes records from the given stream, partitioned by the given partitioning function, and delivers them to a vertex through the given onReceive callback.
	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.)
	NewOutputR(FuncTVertex, VertexOutputR, TTime)	Creates a new output with no partitioning guarantee.
	NewOutputR(FuncTVertex, VertexOutputR, TTime, ExpressionFuncR, Int32)	Creates a new output with a partitioning guarantee
	ToString	Returns the stage name decorated with the stage ID. (Inherited from Stage.)

Top

Fields

	Name	Description
	Placement	the placement used for the stage (Inherited from Stage.)
	StageId	the unique identifier associated with the stage (Inherited from Stage.)

Top

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. (Inherited from StageTTime.)
	Name	Returns the stage name undecorated by stage id (Inherited from Stage.)

Top

Remarks

This class can be instantiated directly using the StageTVertex, TTime(TimeContextTTime, FuncInt32, StageTTime, TVertex, String) constructor, or indirectly using the static factory and extension methods in Foundry.

Reference

Microsoft.Research.Naiad.Dataflow Namespace