BinaryVertexTInput1, TInput2, TOutput, TTimeMakeStage Method (Placement, StreamTInput1, TTime, StreamTInput2, TTime, FuncInt32, StageTTime, BinaryVertexTInput1, TInput2, TOutput, TTime, ExpressionFuncTInput1, Int32, ExpressionFuncTInput2, Int32, ExpressionFuncTOutput, Int32, String)Naiad Help

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

Creates a new stream from the output of a stage of BinaryVertex objects.

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 static Stream<TOutput, TTime> MakeStage(
	Placement placement,
	Stream<TInput1, TTime> stream1,
	Stream<TInput2, TTime> stream2,
	Func<int, Stage<TTime>, BinaryVertex<TInput1, TInput2, TOutput, TTime>> factory,
	Expression<Func<TInput1, int>> input1PartitionBy,
	Expression<Func<TInput2, int>> input2PartitionBy,
	Expression<Func<TOutput, int>> outputPartitionBy,
	string name
)

Parameters

placement
Type: Microsoft.Research.Naiad.DataflowPlacement
Placement to use for vertices in the stage
stream1
Type: Microsoft.Research.NaiadStreamTInput1, TTime
first input stream
stream2
Type: Microsoft.Research.NaiadStreamTInput2, TTime
second input stream
factory
Type: SystemFuncInt32, StageTTime, BinaryVertexTInput1, TInput2, TOutput, TTime
factory from index and stage to BinaryVertex
input1PartitionBy
Type: System.Linq.ExpressionsExpressionFuncTInput1, Int32
first input partitioning requirement
input2PartitionBy
Type: System.Linq.ExpressionsExpressionFuncTInput2, Int32
second input partitioning requirement
outputPartitionBy
Type: System.Linq.ExpressionsExpressionFuncTOutput, Int32
output partitioning guarantee
name
Type: SystemString
friendly name

Return Value

Type: StreamTOutput, TTime
the output stream of the corresponding binary stage.
See Also

Reference