[This is preliminary documentation and is subject to change.]
Represents a single abstract vertex in a dataflow graph, with a time type that indicates its level of nesting in the graph.
Microsoft.Research.Naiad.Dataflow.StandardVerticesBinaryVertexTInput1, TInput2, TOutput, TTime
Microsoft.Research.Naiad.Dataflow.StandardVerticesUnaryVertexTInput, TOutput, TTime
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
public abstract class Vertex<TTime> : Vertex where TTime : Object, Time<TTime>
- The type of timestamps on messages that this vertex processes.
Thetype exposes the following members.
Constructs a new Vertex with the given index in the given stage.
Writes the state of this vertex to the given writer.(Overrides VertexCheckpoint(NaiadWriter).)
Flushes all buffered state at this vertex.(Inherited from Vertex.)
Requests notification after all messages bearing the given time or earlier have been delivered.
Requests a notification once all messages bearing the requirement time have been delivered, with the capability to send messages at a different (potentially later) time.
Indicates that all messages bearing the given time (or earlier) have been delivered.
Called after all messages and notifications have been delivered to this vertex.(Overrides VertexOnShutdown.)
Restores the state of this vertex from the given reader.(Overrides VertexRestore(NaiadReader).)
Returns a string representation of this vertex.(Inherited from Vertex.)
The worker will invoke this method periodically to indicate progress through the computation, and enable (for example) garbage-collection code to run.(Inherited from Vertex.)
Currently available for checkpoint restore(Inherited from Vertex.)
The stage to which this vertex belongs.(Inherited from Vertex.)
Vertex identifier (unique within the same Stage).(Inherited from Vertex.)
Indicates number of additional times the vertex may be entered(Inherited from Vertex.)
Indicates whether the vertex has been shut down(Inherited from Vertex.)
The stream that will be used for logging updates to the vertex state.(Inherited from Vertex.)