[This is preliminary documentation and is subject to change.]
Vertex with two inputs, one output, which calls OnRecv1/OnRecv2 for each input, and OnNotify(time) if ScheduleAt(time) is ever called.
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 abstract class BinaryVertex<TInput1, TInput2, TOutput, TTime> : Vertex<TTime> where TTime : Object, Time<TTime>
Type Parameters
- TInput1
- Source 1 record type
- TInput2
- Source 2 record type
- TOutput
- Result record type
- TTime
- Time type
The BinaryVertexTInput1, TInput2, TOutput, TTime type exposes the following members.
Constructors
Name | Description | |
---|---|---|
BinaryVertexTInput1, TInput2, TOutput, TTime |
Creates a new BinaryVertex
|
Methods
Name | Description | |
---|---|---|
MakeStage(StreamTInput1, TTime, StreamTInput2, TTime, FuncInt32, StageTTime, BinaryVertexTInput1, TInput2, TOutput, TTime, ExpressionFuncTInput1, Int32, ExpressionFuncTInput2, Int32, ExpressionFuncTOutput, Int32, String) |
Creates a new stream from the output of a stage of BinaryVertex objects.
| |
MakeStage(Placement, StreamTInput1, TTime, StreamTInput2, TTime, FuncInt32, StageTTime, BinaryVertexTInput1, TInput2, TOutput, TTime, ExpressionFuncTInput1, Int32, ExpressionFuncTInput2, Int32, ExpressionFuncTOutput, Int32, String) |
Creates a new stream from the output of a stage of BinaryVertex objects.
| |
OnReceive1 |
Called when a message is received on the first input.
| |
OnReceive2 |
Called when a message is received on the second input.
|
Fields
Name | Description | |
---|---|---|
Output |
The buffer for output records.
|
See Also