[This is preliminary documentation and is subject to change.]
Vertex with two inputs, one output, which accumulates inputs and schedules itself for each time seen.
Inheritance Hierarchy
Microsoft.Research.Naiad.DataflowVertex
Microsoft.Research.Naiad.DataflowVertexTTime
Microsoft.Research.Naiad.Dataflow.StandardVerticesBinaryVertexTInput1, TInput2, TOutput, TTime
Microsoft.Research.Naiad.Dataflow.StandardVerticesBinaryBufferingVertexTInput1, TInput2, TOutput, TTime
Namespace: Microsoft.Research.Naiad.Dataflow.StandardVertices
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public class BinaryBufferingVertex<TInput1, TInput2, TOutput, TTime> : BinaryVertex<TInput1, TInput2, TOutput, TTime> where TTime : Object, Time<TTime>
Type Parameters
- TInput1
- Source 1 record type
- TInput2
- Source 2 record type
- TOutput
- Result type
- TTime
- Time type
The BinaryBufferingVertexTInput1, TInput2, TOutput, TTime type exposes the following members.
Constructors
Name | Description | |
---|---|---|
BinaryBufferingVertexTInput1, TInput2, TOutput, TTime |
Constructs a new BinaryBufferingVertex
|
Methods
Name | Description | |
---|---|---|
OnNotify |
Indicates that all messages bearing the given time (or earlier) have been delivered.
(Overrides VertexTTimeOnNotify(TTime).) | |
OnReceive1 |
Called when a message is received on the first input.
(Overrides BinaryVertexTInput1, TInput2, TOutput, TTimeOnReceive1(MessageTInput1, TTime).) | |
OnReceive2 |
Called when a message is received on the second input.
(Overrides BinaryVertexTInput1, TInput2, TOutput, TTimeOnReceive2(MessageTInput2, TTime).) |
Fields
Name | Description | |
---|---|---|
Input1 |
First input buffer
| |
Input2 |
Second input buffer
| |
Output |
The buffer for output records.
(Inherited from BinaryVertexTInput1, TInput2, TOutput, TTime.) |
See Also