DryadLinqQueryableForkT, R1, R2 Method (IQueryableT, ExpressionFuncIEnumerableT, IEnumerableForkTupleR1, R2)DryadLINQ documentation
Forks a specified input dataset into two datasets. A specified user-defined function is applied to each partition of the input dataset to produce a sequence of ForkTuples.

Namespace: Microsoft.Research.DryadLinq
Assembly: Microsoft.Research.DryadLinq (in Microsoft.Research.DryadLinq.dll) Version: 0.2.1.0 (0.2.1.0)
Syntax

public static IMultiQueryable<R1, R2> Fork<T, R1, R2>(
	this IQueryable<T> source,
	Expression<Func<IEnumerable<T>, IEnumerable<ForkTuple<R1, R2>>>> mapper
)

Parameters

source
Type: System.LinqIQueryableT
The input dataset
mapper
Type: System.Linq.ExpressionsExpressionFuncIEnumerableT, IEnumerableForkTupleR1, R2
The function to apply to each partition of the input dataset

Type Parameters

T
The type of the elements of source
R1
The element type of the first output dataset
R2
The element type of the second output dataset

Return Value

Type: IMultiQueryableR1, R2
An IMultiQueryable exposing two output datasets

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type IQueryableT. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).
See Also

Reference