[This is preliminary documentation and is subject to change.]
The GraphLINQ operators are implemented as extension methods on StreamTRecord, TTime objects.
Inheritance Hierarchy
Microsoft.Research.Naiad.Frameworks.GraphLINQExtensionMethods
Namespace: Microsoft.Research.Naiad.Frameworks.GraphLINQ
Assembly: Microsoft.Research.Naiad.GraphLINQ (in Microsoft.Research.Naiad.GraphLINQ.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public static class ExtensionMethods
The ExtensionMethods type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
  | CountNodesTTime |
Computes the number of occurrences of each node in the input.
|
| DistinctNodesTTime |
Computes the distinct set of nodes in the input.
|
| FilterByTValue, TTime |
Filters the stream of nodes to contain only those nodes in the restriction.
|
| FinishRenamingTRecord, TIdentifier |
Extracts a stream from an AutoRenaming context. Once called, no further RenameUsing invocations may be used.
|
| GenerateDenseNameMappingTIdentifier |
Computes a mapping from unique identifiers in the input stream to mostly dense Node indices.
Indices are dense on each worker, but skew among workers can lead to gaps in the tail of the indices.
|
| GraphReduceTValue, TTime |
For each target node in edges, aggregates the values at the neighboring nodes using the given combiner.
|
| NodeAggregateTValue, TTime |
Aggregates the values associated with each node using the given combiner independently for each time.
|
| NodeAggregateLocallyTValue, TTime |
Aggregates the values associated with each node at each process using the given combiner independently for each time.
|
| NodeJoinTValue, TState, TOutput, TTime |
Joins a value stream with a static set of per-node states.
|
| RenameEdgesTIdentifier |
Rewrites the pairs of arbitrary identifiers in edges according to the given renameMapping.
|
| RenameNodesTIdentifier |
Rewrites the arbitrary identifiers in nodes according to the given renameMapping.
|
| RenameUsingTInput, TIdentifier(StreamTInput, Epoch, AutoRenamerTIdentifier, FuncTInput, TIdentifier) |
Uses an AutoRenamer to create and attach names to records in an input stream based on identifiers producer by an identifierSelector function.
|
| RenameUsingTInput, TIdentifier(StreamTInput, Epoch, StreamNodeWithValueTIdentifier, Epoch, FuncTInput, TIdentifier) |
Associates elements of the given stream with nodes selected by the given identifierSelector and renameMapping.
|
| RenameUsingTInput, TIdentifier(StreamTInput, IterationInEpoch, AutoRenamerTIdentifier, FuncTInput, TIdentifier) |
Uses an AutoRenamer to create and attach names to records in an input stream based on identifiers producer by an identifierSelector function.
|
| StateMachineTValue, TState, TTime(StreamNodeWithValueTValue, TTime, FuncTValue, TState, TState) |
Given a stream of values associated with nodes, maintains a state machine for each node,
and produces a stream of new states on each transition, based on the given transitionSelector.
|
| StateMachineTValue, TState, TTime(StreamNodeWithValueTValue, TTime, FuncTValue, TState, TState, TState) |
Given a stream of values associated with nodes, maintains a state machine for each node,
and produces a stream of new states on each transition, based on the given transitionSelector.
|
| StateMachineTValue, TState, TOutput, TTime(StreamNodeWithValueTValue, TTime, FuncTValue, TState, PairTState, TOutput) |
Given a stream of values associated with nodes, maintains a state machine for each node,
and produces outputs on each transition, based on the given transitionSelector.
|
| StateMachineTValue, TState, TOutput, TTime(StreamNodeWithValueTValue, TTime, FuncTValue, TState, PairTState, TOutput, TState) |
Given a stream of values associated with nodes, maintains a state machine for each node,
and produces outputs on each transition, based on the given transitionSelector.
|
| StateMachineTValue, TState, TOutput, TTime(StreamNodeWithValueTValue, TTime, StreamNodeWithValueTState, TTime, FuncTValue, TState, PairTState, TOutput, TState) |
Given a stream of values and a stream of initial states associated with nodes, maintains a state machine for each node,
and produces outputs on each transition, based on the given transitionSelector.
|
| TransmitAlongTValue, TTime(StreamNodeWithValueTValue, TTime, StreamEdge, TTime) |
Transmits the value associated with each node in nodes along the matching edges in edges
to produce a stream of NodeWithValueTValues for each target of a matching edge.
|
| TransmitAlongTValue, TOutput, TTime(StreamNodeWithValueTValue, TTime, StreamEdge, TTime, FuncNodeWithValueTValue, Node, TOutput) |
Transmits the value associated with each node in nodes along the matching edges in edges
to produce a stream of NodeWithValueTValues for each target of a matching edge.
|
See Also