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

public static Stream<TOutput, TTime> MakeStage(
	Placement placement,
	Stream<TInput, TTime> stream,
	Func<int, Stage<TTime>, UnaryVertex<TInput, TOutput, TTime>> factory,
	Expression<Func<TInput, int>> inputPartitionBy,
	Expression<Func<TOutput, int>> outputPartitionBy,
	string name
)

Parameters

placement

Type: Microsoft.Research.Naiad.DataflowPlacement
Placement to use for vertices in the stage

stream

Type: Microsoft.Research.NaiadStreamTInput, TTime
Source data stream

factory

Type: SystemFuncInt32, StageTTime, UnaryVertexTInput, TOutput, TTime
Function from index and stage to a UnaryVertex

inputPartitionBy

Type: System.Linq.ExpressionsExpressionFuncTInput, Int32
input partitioning requirement

outputPartitionBy

Type: System.Linq.ExpressionsExpressionFuncTOutput, Int32
output partitioning guarantee

name

Type: SystemString
console-friendly name

Return Value

Reference