Forks a specified input dataset into three 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, R3> Fork<T, R1, R2, R3>( this IQueryable<T> source, Expression<Func<IEnumerable<T>, IEnumerable<ForkTuple<R1, R2, R3>>>> mapper )
Parameters
- source
- Type: System.Linq.IQueryable<T>
The input dataset - mapper
- Type: System.Linq.Expressions.Expression<Func<IEnumerable<T>, IEnumerable<ForkTuple<R1, R2, R3>>>>
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
- R3
- The element type of the third output dataset
Return Value
Type: IMultiQueryable<R1, R2, R3>An IMultiQueryable exposing three output datasets
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type IQueryable<T>. 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