[This is preliminary documentation and is subject to change.]
The InputCollectionTRecord generic type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
 | AggregateTKey, TValue, TOutput |
Groups records using the supplied key selector, and applies the given aggregation function.
(Inherited from CollectionTRecord, TTime.) |
| CoGroupByTKey, TRecord2, TOutput(CollectionTRecord2, TTime, ExpressionFuncTRecord, TKey, ExpressionFuncTRecord2, TKey, ExpressionFuncTKey, IEnumerableTRecord, IEnumerableTRecord2, IEnumerableTOutput) |
Groups records from both input collections using the respective key selector, and applies the given reduction function.
(Inherited from CollectionTRecord, TTime.) |
| CoGroupByTKey, TValue1, TValue2, TRecord2, TOutput(CollectionTRecord2, TTime, ExpressionFuncTRecord, TKey, ExpressionFuncTRecord2, TKey, ExpressionFuncTRecord, TValue1, ExpressionFuncTRecord2, TValue2, ExpressionFuncTKey, IEnumerableTValue1, IEnumerableTValue2, IEnumerableTOutput) |
Groups records from both input collections using the respective key selector, and applies the given reduction function.
(Inherited from CollectionTRecord, TTime.) |
| Concat |
Computes the concatenation of this collection and the other collection.
(Inherited from CollectionTRecord, TTime.) |
| Consolidate |
Consolidates a collection so that each record occurs with at most one weight.
(Inherited from CollectionTRecord, TTime.) |
| ConsolidateTKey(ExpressionFuncTRecord, TKey) |
Consolidates representation so that each record occurs with at most one weight.
(Inherited from CollectionTRecord, TTime.) |
| CountTKey(ExpressionFuncTRecord, TKey) |
Groups records using the supplied key selector, and counts the number of records in each group.
(Inherited from CollectionTRecord, TTime.) |
| CountTKey, TOutput(ExpressionFuncTRecord, TKey, ExpressionFuncTKey, Int64, TOutput) |
Groups records using the supplied key selector, and counts the number of records in each group.
(Inherited from CollectionTRecord, TTime.) |
| Distinct |
Computes the set of distinct records in this collection.
(Inherited from CollectionTRecord, TTime.) |
| EnterLoop(LoopContextTTime) |
Enables this collection to be used as a constant in the given loop context.
(Inherited from CollectionTRecord, TTime.) |
| EnterLoop(LoopContextTTime, FuncTRecord, Int32) |
Enables this collection to be used in the given loop context, where each record
may be introduced at a different iteration.
(Inherited from CollectionTRecord, TTime.) |
| Except |
Computes the multiset difference of this collection minus the other collection.
(Inherited from CollectionTRecord, TTime.) |
| FixedPoint(FuncLoopContextTTime, CollectionTRecord, IterationInTTime, CollectionTRecord, IterationInTTime) |
Computes the fixed point of the subquery f applied to this collection.
(Inherited from CollectionTRecord, TTime.) |
| FixedPoint(FuncLoopContextTTime, CollectionTRecord, IterationInTTime, CollectionTRecord, IterationInTTime, Int32) |
Computes the fixed point of the subquery f applied to this collection.
(Inherited from CollectionTRecord, TTime.) |
| FixedPointTKey(FuncLoopContextTTime, CollectionTRecord, IterationInTTime, CollectionTRecord, IterationInTTime, ExpressionFuncTRecord, TKey) |
Computes the fixed point of the subquery f applied to this collection.
(Inherited from CollectionTRecord, TTime.) |
| FixedPointTKey(FuncLoopContextTTime, CollectionTRecord, IterationInTTime, CollectionTRecord, IterationInTTime, ExpressionFuncTRecord, TKey, Int32) |
Computes the fixed point of the subquery f applied to this collection.
(Inherited from CollectionTRecord, TTime.) |
| GeneralFixedPointTKey |
Computes the fixed point of the subquery f applied to this collection.
(Inherited from CollectionTRecord, TTime.) |
| GroupByTKey, TOutput(ExpressionFuncTRecord, TKey, FuncTKey, IEnumerableTRecord, IEnumerableTOutput) |
Groups records using the supplied key selector, and applies the given reduction function.
(Inherited from CollectionTRecord, TTime.) |
| GroupByTKey, TValue, TOutput(ExpressionFuncTRecord, TKey, ExpressionFuncTRecord, TValue, FuncTKey, IEnumerableTValue, IEnumerableTOutput) |
Groups records using the supplied key selector, and applies the given reduction function.
(Inherited from CollectionTRecord, TTime.) |
| Intersect |
Computes the multiset intersection of this collection and the other collection.
(Inherited from CollectionTRecord, TTime.) |
| JoinTKey, TRecord2, TOutput(CollectionTRecord2, TTime, ExpressionFuncTRecord, TKey, ExpressionFuncTRecord2, TKey, ExpressionFuncTRecord, TRecord2, TOutput) |
Joins this collection with the other collection, using the respective key selectors.
(Inherited from CollectionTRecord, TTime.) |
| JoinTValue1, TValue2, TRecord2, TOutput(CollectionTRecord2, TTime, ExpressionFuncTRecord, Int32, ExpressionFuncTRecord2, Int32, ExpressionFuncTRecord, TValue1, ExpressionFuncTRecord2, TValue2, ExpressionFuncInt32, TValue1, TValue2, TOutput, Boolean) |
Joins this collection with the other collection, using the respective integer-valued key selectors.
(Inherited from CollectionTRecord, TTime.) |
| JoinTKey, TValue1, TValue2, TRecord2, TOutput(CollectionTRecord2, TTime, ExpressionFuncTRecord, TKey, ExpressionFuncTRecord2, TKey, ExpressionFuncTRecord, TValue1, ExpressionFuncTRecord2, TValue2, ExpressionFuncTKey, TValue1, TValue2, TOutput) |
Joins this collection with the other collection, using the respective key selectors.
(Inherited from CollectionTRecord, TTime.) |
| MaxTKey, TComparable(ExpressionFuncTRecord, TKey, ExpressionFuncTRecord, TComparable) |
Groups records using the supplied key selector, and computes the maximum value in each group.
(Inherited from CollectionTRecord, TTime.) |
| MaxTKey, TComparable, TValue(ExpressionFuncTRecord, TKey, ExpressionFuncTRecord, TValue, ExpressionFuncTKey, TValue, TComparable, ExpressionFuncTKey, TValue, TRecord) |
Groups records using the supplied key selector, and computes the maximum value in each group.
(Inherited from CollectionTRecord, TTime.) |
| MinTKey, TComparable(ExpressionFuncTRecord, TKey, ExpressionFuncTRecord, TComparable) |
Groups records using the supplied key selector, and computes the minimum value in each group.
(Inherited from CollectionTRecord, TTime.) |
| MinTValue, TComparable(ExpressionFuncTRecord, Int32, ExpressionFuncTRecord, TValue, ExpressionFuncInt32, TValue, TComparable, ExpressionFuncInt32, TValue, TRecord, Boolean) |
Groups records using the supplied integer-valued key selector, and computes the minimum value in each group.
(Inherited from CollectionTRecord, TTime.) |
| MinTKey, TComparable, TValue(ExpressionFuncTRecord, TKey, ExpressionFuncTRecord, TValue, ExpressionFuncTKey, TValue, TComparable, ExpressionFuncTKey, TValue, TRecord) |
Groups records using the supplied key selector, and computes the minimum value in each group.
(Inherited from CollectionTRecord, TTime.) |
| Monitor |
Applies the given action to the records in this collection once for each timestamp on each worker, for monitoring.
(Inherited from CollectionTRecord, TTime.) |
| OnCompleted |
Signals that no more records will be added to or removed from this collection.
|
| OnCompleted(IEnumerableWeightedTRecord) |
Introduces a batch of values to this collection in a new Epoch, and signals that no more records will be added to or removed from this collection.
|
| OnNext |
Introduces a batch of values to this collection in a new Epoch.
|
| PartitionByTKey |
Partitions a collection by the given key selector.
(Inherited from CollectionTRecord, TTime.) |
| SelectTOutput |
Transforms each record in the collection using the given selector function.
(Inherited from CollectionTRecord, TTime.) |
| SelectManyTOutput(ExpressionFuncTRecord, IEnumerableTOutput) |
Transforms each record in the collection using the given selector function and flattens the result.
(Inherited from CollectionTRecord, TTime.) |
| SumTKey, TOutput(ExpressionFuncTRecord, TKey, ExpressionFuncTRecord, Int32, ExpressionFuncTKey, Int32, TOutput) |
Groups records using the supplied key selector, and computes the sum of the records in each group.
(Inherited from CollectionTRecord, TTime.) |
| SymmetricDifference |
Computes the multiset symmetric difference of this collection and the other collection.
(Inherited from CollectionTRecord, TTime.) |
| Union |
Computes the multiset union of this collection and the other collection.
(Inherited from CollectionTRecord, TTime.) |
| Where |
Filters the collection to contain only records that match the given predicate.
(Inherited from CollectionTRecord, TTime.) |
Extension Methods
| Name | Description | |
|---|---|---|
 | OnCompletedTRecord(IEnumerableTRecord) | Overloaded.
Adds several records and signals that the InputCollectionTRecord is complete.
(Defined by ExtensionMethods.) |
| OnCompletedTRecord(TRecord) | Overloaded.
Adds a single record and signals that the InputCollectionTRecord is complete.
(Defined by ExtensionMethods.) |
| OnCompletedTRecord(WeightedTRecord) | Overloaded.
Adds a single record with an integer weight and signals that the InputCollectionTRecord is complete.
(Defined by ExtensionMethods.) |
| OnNextTRecord | Overloaded.
Introduces no records to a InputCollectionTRecord.
(Defined by ExtensionMethods.) |
| OnNextTRecord(IEnumerableTRecord) | Overloaded.
Adds records to an InputCollectionTRecord.
(Defined by ExtensionMethods.) |
| OnNextTRecord(TRecord) | Overloaded.
Adds a record to an InputCollectionTRecord.
(Defined by ExtensionMethods.) |
| OnNextTRecord(IEnumerableTRecord, Int32) | Overloaded.
Introduces several records to an InputCollectionTRecord with the same integer weight.
(Defined by ExtensionMethods.) |
| OnNextTRecord(TRecord, Int32) | Overloaded.
Introduces a record to an InputCollectionTRecord with an integer weight.
(Defined by ExtensionMethods.) |
See Also