NonStandardExtensionMethods ClassNaiad Help

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

Less standard LINQ-ish methods exposing loops and parallelism.
Inheritance Hierarchy
SystemObject
  Microsoft.Research.Naiad.Frameworks.LindiNonStandardExtensionMethods

Namespace: Microsoft.Research.Naiad.Frameworks.Lindi
Assembly: Microsoft.Research.Naiad.Lindi (in Microsoft.Research.Naiad.Lindi.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
Copy
public static class NonStandardExtensionMethods

The NonStandardExtensionMethods type exposes the following members.

Methods
  NameDescription
Public methodStatic memberIterateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, Int32, String)
Iteratively applies function to the given stream.
Public methodStatic memberIterateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, ExpressionFuncTRecord, Int32, Int32, String)
Iteratively applies function to the given stream.
Public methodStatic memberIterateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, FuncTRecord, Int32, ExpressionFuncTRecord, Int32, Int32, String)
Iteratively applies function to the given stream.
Public methodStatic memberIterateAndAccumulateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, Int32, String)
Iteratively applies function to the given stream and accumulates all of the iterates.
Public methodStatic memberIterateAndAccumulateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, ExpressionFuncTRecord, Int32, Int32, String)
Iteratively applies function to the given stream and accumulates all of the iterates.
Public methodStatic memberIterateAndAccumulateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, FuncTRecord, Int32, ExpressionFuncTRecord, Int32, Int32, String)
Iteratively applies function to the given stream and accumulates all of the iterates.
Public methodStatic memberSelectByVertexTInput, TOutput, TTime
Transforms each record in the input stream using the given selector function.
Public methodStatic memberSelectManyArraySegmentTInput, TOutput, TTime
Transforms each record in the collection using the given selector function and flattens the result.
Public methodStatic memberSynchronizeTRecord, TTime
For each timestamp, buffers the given stream until all workers have all input for that time, and then releases the buffer.
Public methodStatic memberWriteToFilesTInput
Writes the records in the given stream to files.
Top
See Also

Reference

Microsoft.Research.Naiad.Frameworks.Lindi Namespace