[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, TTimethe output stream of the corresponding binary stage.
See Also