[This is preliminary documentation and is subject to change.]

public interface InputCollection<TRecord> : Collection<TRecord, Epoch>, 
	IObserver<IEnumerable<Weighted<TRecord>>>
where TRecord : Object, IEquatable<TRecord>

Type Parameters

TRecord

The type of records in this collection.

The InputCollectionTRecord type exposes the following members.

	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.)

	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.)

	Name	Description
	Output	The underlying Naiad StreamTRecord, TTime of WeightedTRecord elements. (Inherited from CollectionTRecord, TTime.)

Reference