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, R2An 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