Represents the placement of physical dataflow Vertex objects in a StageTTime.

Represents a Placement based on an explicit Vertex-to-location mapping.

Placement with one vertex

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.

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.

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.

Represents an input to a dataflow stage.

Represents a single abstract vertex in a dataflow graph. (In Naiad, most concrete vertices extend VertexTTime.)

Represents a single abstract vertex in a dataflow graph, with a time type that indicates its level of nesting in the graph.

A repository for input records, stored indexed by time. Calls NotifyAt on record receipt.

An intermediate buffer for records sent by a Vertex.

Represents a per-time buffer for sending records with a single time.

Represents a non-varying logical time.

Represents the logical timestamp in a streaming context.

Represents the logical timestamp containing a loop counter nested within another logical TTime context.

A message containing typed records all with a common time

Describes the origin of a message

Represents a potentially nested scope in a dataflow computation, in which all messages have the same time type.

Describes the physical location of a dataflow Vertex.

Represents the recipient of a MessageTRecord, TTime

Represents a streaming input to a Naiad computation.

Defines the input of a vertex, which must process messages and manage re-entrancy for the runtime.

Represents an output of a vertex, to which zero or more SendChannelTRecord, TTime (receivers) can be added.