Collection(TRecord, TTime).Monitor Method

CollectionTRecord, TTimeMonitor Method

Naiad Help

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

Applies the given action to the records in this collection once for each timestamp on each worker, for monitoring.

Namespace: Microsoft.Research.Naiad.Frameworks.DifferentialDataflow
Assembly: Microsoft.Research.Naiad.DifferentialDataflow (in Microsoft.Research.Naiad.DifferentialDataflow.dll) Version: 0.5.0.0 (0.5.0.0)

Syntax

Collection<TRecord, TTime> Monitor(
	Action<int, List<Pair<Weighted<TRecord>, TTime>>> action
)

action: Type: SystemActionInt32, ListPairWeightedTRecord, TTime
The action to apply to each group of records, and the respective worker index.

Type: CollectionTRecord, TTime
The input collection.