| Interface | Description |
|---|---|
| AggregateFunc<T> | |
| WindowComputeFunc<O,I> |
WindowCompute is the TSet ComputeFunction extension for Windowing oriented computations
|
| Class | Description |
|---|---|
| FlatMapCompute<O,I> | |
| FlatMapIterCompute<O,I> | |
| ForEachCompute<T> | |
| ForEachIterCompute<T> | |
| GatherFlatMapCompute<O,I> | |
| GatherForEachCompute<T> | |
| GatherMapCompute<O,I> | |
| HashingPartitioner<T> | |
| IdentitySelector<T> | |
| LoadBalancePartitioner<T> | |
| MapCompute<O,I> | |
| MapIterCompute<O,I> | |
| OneToOnePartitioner<T> |
Go from one task to a corresponding task
|
| ProcessWindowCompute<O,I> |