Keyword(s) for which to search:
Sort results by title
Keyword Index
Direct Link
Welcome to Naiad
Writing your first Naiad program
Running Naiad programs on Microsoft Azure
Implementing a custom Naiad vertex
Version History
Version 0.5
Version 0.4
Version 0.2
Version 0.3
Version 0.1
Naiad SDK
Microsoft.Research.Naiad
AllocationReason Enumeration
Computation Interface
Computation Methods
Activate Method
Join Method
NewInput Method
NewInput(TRecord) Method (DataSource(TRecord))
NewInput(TRecord) Method (DataSource(TRecord), String)
Sync Method
Computation Properties
Controller Property
Computation Events
OnFrontierChange Event
OnShutdown Event
OnStartup Event
Configuration Class
Configuration Constructor
Configuration Methods
BuildFromArguments Method
FromArgs Method
Usage Method
Configuration Properties
AdditionalSettings Property
Broadcast Property
BroadcastAddress Property
CompactionInterval Property
DeadlockTimeout Property
DistributedProgressTracker Property
DuplexSockets Property
Endpoints Property
KeepAlives Property
MultipleLocalProcesses Property
Nagling Property
Processes Property
ProcessID Property
ReadEndpointsFromPPM Property
SendBufferPolicy Property
SendPageCount Property
SendPageSize Property
UseBroadcastWakeup Property
UseInlineSerialization Property
UseNetworkBroadcastWakeup Property
WorkerCount Property
Configuration.BroadcastProtocol Enumeration
Configuration.SendBufferMode Enumeration
Controller Interface
Controller Methods
Join Method
JoinAsync Method
NewComputation Method
Controller Properties
Configuration Property
DefaultPlacement Property
SerializationFormat Property
WorkerGroup Property
NewComputation Class
NewComputation Methods
FromArgs Method
FromConfig Method
NewController Class
NewController Methods
FromArgs Method
FromConfig Method
OneOffComputation Interface
OneOffComputation Methods
OneOffComputation Properties
Configuration Property
DefaultPlacement Property
WorkerGroup Property
OneOffComputation Events
Pair(TFirst, TSecond) Structure
Pair(TFirst, TSecond) Constructor
Pair(TFirst, TSecond) Fields
First Field
Second Field
Pair(TFirst, TSecond) Methods
Equals Method
GetHashCode Method
ToString Method
PairExtensionMethods Class
PairExtensionMethods Methods
PairWith(V1, V2) Method
Stream(TRecord, TTime) Class
Stream(TRecord, TTime) Properties
Context Property
ForStage Property
PartitionedBy Property
SubscribeExtensionMethods Class
SubscribeExtensionMethods Methods
Subscribe Method
Subscribe(R) Method (Stream(R, Epoch))
Subscribe(R) Method (Stream(R, Epoch), Action(IEnumerable(R)))
Subscribe(R) Method (Stream(R, Epoch), Action(Int32, IEnumerable(R)))
Subscribe(R) Method (Stream(R, Epoch), Action(Int32, Int32, IEnumerable(R)))
Subscribe(R) Method (Stream(R, Epoch), Action(Message(R, Epoch), Int32), Action(Epoch, Int32), Action(Int32))
Subscription Interface
Subscription Methods
Sync Method
Time(TTime) Interface
Time(TTime) Methods
GetHashCode Method
InitializeFrom Method
Join Method
LessThan Method
Meet Method
Populate Method
Time(TTime) Properties
Coordinates Property
WorkerGroup Interface
WorkerGroup Properties
Count Property
WorkerGroup Events
Sleeping Event
Starting Event
Terminating Event
Waking Event
WorkItemEnding Event
WorkItemEnqueued Event
WorkItemStarting Event
Microsoft.Research.Naiad.Dataflow
Empty Structure
Empty Fields
zero Field
Empty Methods
CompareTo Method
Equals Method
GetHashCode Method
InitializeFrom Method
Join Method
LessThan Method
Meet Method
Populate Method
Empty Properties
Coordinates Property
Epoch Structure
Epoch Constructor
Epoch Fields
epoch Field
Epoch Methods
CompareTo Method
Equals Method
GetHashCode Method
InitializeFrom Method
Join Method
LessThan Method
Meet Method
Populate Method
ToString Method
Epoch Properties
Coordinates Property
IterationIn(TTime) Structure
IterationIn(TTime) Constructor
IterationIn(TTime) Fields
iteration Field
outerTime Field
IterationIn(TTime) Methods
CompareTo Method
Equals Method
GetHashCode Method
InitializeFrom Method
Join Method
LessThan Method
Meet Method
Populate Method
ToString Method
IterationIn(TTime) Properties
Coordinates Property
Message(TRecord, TTime) Structure
Message(TRecord, TTime) Fields
length Field
payload Field
time Field
Message(TRecord, TTime) Methods
Allocate Method
Release Method
Message(TRecord, TTime) Properties
Unallocated Property
Placement Class
Placement Constructor
Placement Methods
Equals Method
GetEnumerator Method
Placement Properties
Count Property
Item Property
Placement.Explicit Class
Placement.Explicit Constructor
Explicit Methods
Equals Method
GetEnumerator Method
Explicit Properties
Count Property
Item Property
Placement.SingleVertex Class
Placement.SingleVertex Constructor
SingleVertex Methods
Equals Method
GetEnumerator Method
SingleVertex Properties
Count Property
Item Property
ReturnAddress Structure
ReturnAddress Constructor
ReturnAddress Constructor (Int32, Int32)
ReturnAddress Constructor (Int32, Int32, Int32)
ReturnAddress Fields
ProcessID Field
ThreadIndex Field
VertexID Field
SendChannel(TRecord, TTime) Interface
SendChannel(TRecord, TTime) Methods
Flush Method
Send Method
Stage Class
Stage Fields
Placement Field
StageId Field
Stage Methods
NewInput Method
NewInput(TRecord, TTime) Method (Stream(TRecord, TTime), Expression(Func(TRecord, Int32)))
NewInput(TRecord, TTime) Method (Stream(TRecord, TTime), Expression(Func(TRecord, Int32)), Action(TRecord[], Int32[], Int32))
ToString Method
Stage Properties
Computation Property
Name Property
Stage(TTime) Class
Stage(TTime) Fields
Stage(TTime) Methods
Stage(TTime) Properties
Context Property
Stage(TVertex, TTime) Class
Stage(TVertex, TTime) Constructor
Stage(TVertex, TTime) Fields
Stage(TVertex, TTime) Methods
NewInput Method
NewInput(TRecord) Method (Stream(TRecord, TTime), Action(Message(TRecord, TTime), TVertex), Expression(Func(TRecord, Int32)))
NewInput(TRecord) Method (Stream(TRecord, TTime), Action(Message(TRecord, TTime), TVertex), Expression(Func(TRecord, Int32)), Action(TRecord[], Int32[], Int32))
NewOutput Method
NewOutput(R) Method (Func(TVertex, VertexOutput(R, TTime)))
NewOutput(R) Method (Func(TVertex, VertexOutput(R, TTime)), Expression(Func(R, Int32)))
Stage(TVertex, TTime) Properties
StageInput(TRecord, TTime) Class
StageInput(TRecord, TTime) Methods
ToString Method
StreamingInput(TRecord) Interface
StreamingInput(TRecord) Methods
OnCompleted Method
OnStreamingNotify Method
OnStreamingRecv Method
StreamingInput(TRecord) Properties
WorkerId Property
TimeContext(TTime) Structure
Vertex Class
Vertex Fields
isShutdown Field
Stage Field
VertexId Field
Vertex Methods
AddOnFlushAction Method
Checkpoint Method
Flush Method
OnShutdown Method
Restore Method
ToString Method
UpdateReachability Method
Vertex Properties
Entrancy Property
IsShutDown Property
LoggingOutput Property
Vertex(TTime) Class
Vertex(TTime) Constructor
Vertex(TTime) Fields
Vertex(TTime) Methods
Checkpoint Method
NotifyAt Method
NotifyAt Method (TTime)
NotifyAt Method (TTime, TTime)
OnNotify Method
OnShutdown Method
Restore Method
Vertex(TTime) Properties
VertexInput(TRecord, TTime) Interface
VertexInput(TRecord, TTime) Methods
Flush Method
OnReceive Method
SerializedMessageReceived Method
VertexInput(TRecord, TTime) Properties
AvailableEntrancy Property
LoggingEnabled Property
Vertex Property
VertexInputBuffer(TRecord, TTime) Class
VertexInputBuffer(TRecord, TTime) Constructor
VertexInputBuffer(TRecord, TTime) Methods
Checkpoint Method
Flush Method
GetRecordsAt Method
OnReceive Method
Restore Method
SerializedMessageReceived Method
ToString Method
VertexInputBuffer(TRecord, TTime) Properties
AvailableEntrancy Property
LoggingEnabled Property
Vertex Property
VertexLocation Structure
VertexLocation Constructor
VertexLocation Fields
ProcessId Field
ThreadId Field
VertexId Field
VertexOutput(TRecord, TTime) Interface
VertexOutput(TRecord, TTime) Methods
AddReceiver Method
VertexOutput(TRecord, TTime) Properties
Vertex Property
VertexOutputBuffer(TRecord, TTime) Class
VertexOutputBuffer(TRecord, TTime) Constructor
VertexOutputBuffer(TRecord, TTime) Methods
AddReceiver Method
Flush Method
GetBufferForTime Method
Send Method
VertexOutputBuffer(TRecord, TTime) Properties
Vertex Property
VertexOutputBufferPerTime(TRecord, TTime) Class
VertexOutputBufferPerTime(TRecord, TTime) Methods
Send Method
Microsoft.Research.Naiad.Dataflow.Iteration
Feedback(TRecord, TTime) Class
Feedback(TRecord, TTime) Properties
Input Property
Output Property
LoopContext(TTime) Class
LoopContext(TTime) Constructor
LoopContext(TTime) Methods
Delay Method
Delay(TRecord) Method
Delay(TRecord) Method (Int32)
Delay(TRecord) Method (Expression(Func(TRecord, Int32)))
Delay(TRecord) Method (Expression(Func(TRecord, Int32)), Int32)
EnterLoop Method
EnterLoop(TRecord) Method (Stream(TRecord, TTime))
EnterLoop(TRecord) Method (Stream(TRecord, TTime), Func(TRecord, Int32))
ExitLoop Method
ExitLoop(TRecord) Method (Stream(TRecord, IterationIn(TTime)))
ExitLoop(TRecord) Method (Stream(TRecord, IterationIn(TTime)), Int32)
Microsoft.Research.Naiad.Dataflow.PartitionBy
ExtensionMethods Class
ExtensionMethods Methods
AssertPartitionedBy(TRecord, TTime) Method
AssumePartitionedBy(TRecord, TTime) Method
PartitionBy(TRecord, TTime) Method
Microsoft.Research.Naiad.Dataflow.StandardVertices
BinaryBufferingVertex(TInput1, TInput2, TOutput, TTime) Class
BinaryBufferingVertex(TInput1, TInput2, TOutput, TTime) Constructor
BinaryBufferingVertex(TInput1, TInput2, TOutput, TTime) Fields
Input1 Field
Input2 Field
BinaryBufferingVertex(TInput1, TInput2, TOutput, TTime) Methods
OnNotify Method
OnReceive1 Method
OnReceive2 Method
BinaryVertex(TInput1, TInput2, TOutput, TTime) Class
BinaryVertex(TInput1, TInput2, TOutput, TTime) Constructor
BinaryVertex(TInput1, TInput2, TOutput, TTime) Fields
Output Field
BinaryVertex(TInput1, TInput2, TOutput, TTime) Methods
MakeStage Method
MakeStage Method (Stream(TInput1, TTime), Stream(TInput2, TTime), Func(Int32, Stage(TTime), BinaryVertex(TInput1, TInput2, TOutput, TTime)), Expression(Func(TInput1, Int32)), Expression(Func(TInput2, Int32)), Expression(Func(TOutput, Int32)), String)
MakeStage Method (Placement, Stream(TInput1, TTime), Stream(TInput2, TTime), Func(Int32, Stage(TTime), BinaryVertex(TInput1, TInput2, TOutput, TTime)), Expression(Func(TInput1, Int32)), Expression(Func(TInput2, Int32)), Expression(Func(TOutput, Int32)), String)
OnReceive1 Method
OnReceive2 Method
ExtensionMethods Class
ExtensionMethods Methods
BinaryExpression(TInput1, TInput2, TOutput, TTime) Method
UnaryExpression(TInput, TOutput, TTime) Method
Foundry Class
Foundry Methods
NewBinaryStage(TInput1, TInput2, TOutput, TTime) Method
NewSinkStage(TOutput, TTime) Method
NewStage Method
NewStage(TVertex, TTime) Method (TimeContext(TTime), Func(Int32, Stage(TTime), TVertex), String)
NewStage(TVertex, TTime) Method (Placement, TimeContext(TTime), Func(Int32, Stage(TTime), TVertex), String)
NewUnaryStage(TInput, TOutput, TTime) Method
SinkBufferingVertex(TOutput, TTime) Class
SinkBufferingVertex(TOutput, TTime) Constructor
SinkBufferingVertex(TOutput, TTime) Fields
Input Field
SinkBufferingVertex(TOutput, TTime) Methods
OnNotify Method
OnReceive Method
SinkVertex(TOutput, TTime) Class
SinkVertex(TOutput, TTime) Constructor
SinkVertex(TOutput, TTime) Methods
MakeStage Method
OnReceive Method
UnaryBufferingVertex(TInput, TOutput, TTime) Class
UnaryBufferingVertex(TInput, TOutput, TTime) Constructor
UnaryBufferingVertex(TInput, TOutput, TTime) Fields
Input Field
UnaryBufferingVertex(TInput, TOutput, TTime) Methods
OnNotify Method
OnReceive Method
UnaryVertex(TInput, TOutput, TTime) Class
UnaryVertex(TInput, TOutput, TTime) Constructor
UnaryVertex(TInput, TOutput, TTime) Fields
Output Field
UnaryVertex(TInput, TOutput, TTime) Methods
MakeStage Method
MakeStage Method (Stream(TInput, TTime), Func(Int32, Stage(TTime), UnaryVertex(TInput, TOutput, TTime)), Expression(Func(TInput, Int32)), Expression(Func(TOutput, Int32)), String)
MakeStage Method (Placement, Stream(TInput, TTime), Func(Int32, Stage(TTime), UnaryVertex(TInput, TOutput, TTime)), Expression(Func(TInput, Int32)), Expression(Func(TOutput, Int32)), String)
OnReceive Method
Microsoft.Research.Naiad.Diagnostics
FrontierChangedEventArgs Class
FrontierChangedEventArgs Constructor
FrontierChangedEventArgs Fields
NewFrontier Field
KernelLoggerTracing Class
KernelLoggerTracing Constructor
KernelLoggerTracing Methods
PostKernelLoggerMarkEvent Method
PostKernelLoggerMarkEvent Method (String)
PostKernelLoggerMarkEvent Method (String, Object[])
TraceConsumer Method
TraceProducer Method
Logging Class
Logging Fields
LogStyle Field
Logging Methods
Assert Method
Assert Method (Boolean)
Assert Method (Boolean, String, Object[])
Debug Method
Error Method
Fatal Method
Info Method
InspectBuffer Method
Progress Method
Stop Method
Logging Properties
LogLevel Property
LoggingLevel Enumeration
LoggingStyle Enumeration
NaiadTracingRegion Enumeration
VertexEndArgs Class
VertexEndArgs Fields
Pointstamp Field
Stage Field
ThreadId Field
VertexId Field
VertexEnqueuedArgs Class
VertexEnqueuedArgs Fields
Pointstamp Field
Stage Field
ThreadId Field
VertexId Field
VertexStartArgs Class
VertexStartArgs Fields
Pointstamp Field
Stage Field
ThreadId Field
VertexId Field
WorkerSleepArgs Class
WorkerSleepArgs Fields
ThreadId Field
WorkerStartArgs Class
WorkerStartArgs Fields
ThreadId Field
WorkerTerminateArgs Class
WorkerTerminateArgs Fields
ThreadId Field
WorkerWakeArgs Class
WorkerWakeArgs Fields
ThreadId Field
Microsoft.Research.Naiad.Frameworks.Azure
ConsoleExtensionMethods Class
ConsoleExtensionMethods Methods
SetConsoleError Method
SetConsoleOut Method
ExtensionMethods Class
ExtensionMethods Methods
DefaultAccount Method
DefaultBlobContainer Method
ReadBinaryFromAzureBlobs(TRecord) Method
ReadCustomBinaryFromAzureBlobs(R) Method
ReadFromAzureBlobs(TRecord) Method
ReadFromAzureTable(TEntity) Method
ReadTextFromAzureBlobs Method
WriteBinaryToAzureBlobs(TRecord) Method
WriteCustomBinaryToAzureBlobs(TRecord) Method
WriteTextToAzureBlobs Method
WriteTextToAzureBlobs Method (Stream(String, Epoch), CloudBlobContainer, String)
WriteTextToAzureBlobs(TRecord) Method (Stream(TRecord, Epoch), CloudBlobContainer, String)
WriteToAzureBlobs(TRecord) Method
Microsoft.Research.Naiad.Frameworks.DifferentialDataflow
Collection(TRecord, TTime) Interface
Collection(TRecord, TTime) Methods
Aggregate(TKey, TValue, TOutput) Method
CoGroupBy Method
CoGroupBy(TKey, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, TKey)), Expression(Func(TRecord2, TKey)), Expression(Func(TKey, IEnumerable(Weighted(TRecord)), IEnumerable(Weighted(TRecord2)), IEnumerable(Weighted(TOutput)))))
CoGroupBy(TKey, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, TKey)), Expression(Func(TRecord2, TKey)), Expression(Func(TKey, IEnumerable(TRecord), IEnumerable(TRecord2), IEnumerable(TOutput))))
CoGroupBy(TKey, TValue1, TValue2, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, TKey)), Expression(Func(TRecord2, TKey)), Expression(Func(TRecord, TValue1)), Expression(Func(TRecord2, TValue2)), Expression(Func(TKey, IEnumerable(Weighted(TValue1)), IEnumerable(Weighted(TValue2)), IEnumerable(Weighted(TOutput)))))
CoGroupBy(TKey, TValue1, TValue2, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, TKey)), Expression(Func(TRecord2, TKey)), Expression(Func(TRecord, TValue1)), Expression(Func(TRecord2, TValue2)), Expression(Func(TKey, IEnumerable(TValue1), IEnumerable(TValue2), IEnumerable(TOutput))))
Concat Method
Consolidate Method
Consolidate Method
Consolidate(TKey) Method (Expression(Func(TRecord, TKey)))
Count Method
Count(TKey) Method (Expression(Func(TRecord, TKey)))
Count(TKey, TOutput) Method (Expression(Func(TRecord, TKey)), Expression(Func(TKey, Int64, TOutput)))
Distinct Method
EnterLoop Method
EnterLoop Method (LoopContext(TTime))
EnterLoop Method (LoopContext(TTime), Func(TRecord, Int32))
Except Method
FixedPoint Method
FixedPoint Method (Func(LoopContext(TTime), Collection(TRecord, IterationIn(TTime)), Collection(TRecord, IterationIn(TTime))))
FixedPoint Method (Func(LoopContext(TTime), Collection(TRecord, IterationIn(TTime)), Collection(TRecord, IterationIn(TTime))), Int32)
FixedPoint(TKey) Method (Func(LoopContext(TTime), Collection(TRecord, IterationIn(TTime)), Collection(TRecord, IterationIn(TTime))), Expression(Func(TRecord, TKey)))
FixedPoint(TKey) Method (Func(LoopContext(TTime), Collection(TRecord, IterationIn(TTime)), Collection(TRecord, IterationIn(TTime))), Expression(Func(TRecord, TKey)), Int32)
GeneralFixedPoint(TKey) Method
GroupBy Method
GroupBy(TKey, TOutput) Method (Expression(Func(TRecord, TKey)), Func(TKey, IEnumerable(TRecord), IEnumerable(TOutput)))
GroupBy(TKey, TValue, TOutput) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, TValue)), Func(TKey, IEnumerable(TValue), IEnumerable(TOutput)))
Intersect Method
Join Method
Join(TKey, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, TKey)), Expression(Func(TRecord2, TKey)), Expression(Func(TRecord, TRecord2, TOutput)))
Join(TKey, TValue1, TValue2, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, TKey)), Expression(Func(TRecord2, TKey)), Expression(Func(TRecord, TValue1)), Expression(Func(TRecord2, TValue2)), Expression(Func(TKey, TValue1, TValue2, TOutput)))
Join(TValue1, TValue2, TRecord2, TOutput) Method (Collection(TRecord2, TTime), Expression(Func(TRecord, Int32)), Expression(Func(TRecord2, Int32)), Expression(Func(TRecord, TValue1)), Expression(Func(TRecord2, TValue2)), Expression(Func(Int32, TValue1, TValue2, TOutput)), Boolean)
Max Method
Max(TKey, TComparable) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, TComparable)))
Max(TKey, TComparable, TValue) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, TValue)), Expression(Func(TKey, TValue, TComparable)), Expression(Func(TKey, TValue, TRecord)))
Min Method
Min(TKey, TComparable) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, TComparable)))
Min(TKey, TComparable, TValue) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, TValue)), Expression(Func(TKey, TValue, TComparable)), Expression(Func(TKey, TValue, TRecord)))
Min(TValue, TComparable) Method (Expression(Func(TRecord, Int32)), Expression(Func(TRecord, TValue)), Expression(Func(Int32, TValue, TComparable)), Expression(Func(Int32, TValue, TRecord)), Boolean)
Monitor Method
PartitionBy(TKey) Method
Select(TOutput) Method
SelectMany Method
SelectMany(TOutput) Method (Expression(Func(TRecord, IEnumerable(ArraySegment(TOutput)))))
SelectMany(TOutput) Method (Expression(Func(TRecord, IEnumerable(TOutput))))
Sum Method
Sum(TKey, TOutput) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, Double)), Expression(Func(TKey, Double, TOutput)))
Sum(TKey, TOutput) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, Int32)), Expression(Func(TKey, Int32, TOutput)))
Sum(TKey, TOutput) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, Int64)), Expression(Func(TKey, Int64, TOutput)))
Sum(TKey, TOutput) Method (Expression(Func(TRecord, TKey)), Expression(Func(TRecord, Single)), Expression(Func(TKey, Single, TOutput)))
SymmetricDifference Method
Union Method
Where Method
Collection(TRecord, TTime) Properties
Output Property
ExtensionMethods Class
ExtensionMethods Methods
AdjustTime(TRecord, TTime) Method
AsCollection(TRecord, TTime) Method
AssumeImmutable(TRecord, TTime) Method
AssumePartitionedBy(TRecord, TTime, TKey) Method
OnCompleted Method
OnCompleted(TRecord) Method (InputCollection(TRecord), Weighted(TRecord))
OnCompleted(TRecord) Method (InputCollection(TRecord), IEnumerable(TRecord))
OnCompleted(TRecord) Method (InputCollection(TRecord), TRecord)
OnNext Method
OnNext(TRecord) Method (InputCollection(TRecord))
OnNext(TRecord) Method (InputCollection(TRecord), IEnumerable(TRecord))
OnNext(TRecord) Method (InputCollection(TRecord), TRecord)
OnNext(TRecord) Method (InputCollection(TRecord), IEnumerable(TRecord), Int32)
OnNext(TRecord) Method (InputCollection(TRecord), TRecord, Int32)
SlidingWindow Method
SlidingWindow(TRecord) Method (Collection(TRecord, Epoch), Int32)
SlidingWindow(TRecord) Method (Stream(TRecord, Epoch), Int32)
Subscribe(TRecord) Method
ToWeighted(TRecord) Method
InputCollection(TRecord) Interface
InputCollection(TRecord) Methods
OnCompleted Method
OnCompleted Method
OnCompleted Method (IEnumerable(Weighted(TRecord)))
OnNext Method
InputCollection(TRecord) Properties
InputCollectionExtensionMethods Class
InputCollectionExtensionMethods Methods
NewInputCollection(TRecord) Method
IntPair Structure
IntPair Constructor
IntPair Fields
s Field
t Field
IntPair Methods
Equals Method
GetHashCode Method
ToString Method
Weighted(TRecord) Structure
Weighted(TRecord) Constructor
Weighted(TRecord) Fields
record Field
weight Field
Weighted(TRecord) Methods
Equals Method
ToString Method
Microsoft.Research.Naiad.Frameworks.GraphLINQ
AutoRenamer(TIdentifier) Class
AutoRenamer(TIdentifier) Constructor
AutoRenamer(TIdentifier) Methods
AddRenameTask(TInput) Method
Dispose Method
AutoRenamer(TIdentifier) Properties
FinalRenamings Property
Edge Structure
Edge Constructor
Edge Fields
source Field
target Field
Edge Methods
Equals Method
GetHashCode Method
ToString Method
EdgeWithValue(TValue) Structure
EdgeWithValue(TValue) Constructor
EdgeWithValue(TValue) Fields
edge Field
value Field
EdgeWithValue(TValue) Methods
GetHashCode Method
ExtensionMethods Class
ExtensionMethods Methods
CountNodes(TTime) Method
DistinctNodes(TTime) Method
FilterBy(TValue, TTime) Method
FinishRenaming(TRecord, TIdentifier) Method
GenerateDenseNameMapping(TIdentifier) Method
GraphReduce(TValue, TTime) Method
NodeAggregate(TValue, TTime) Method
NodeAggregateLocally(TValue, TTime) Method
NodeJoin(TValue, TState, TOutput, TTime) Method
RenameEdges(TIdentifier) Method
RenameNodes(TIdentifier) Method
RenameUsing Method
RenameUsing(TInput, TIdentifier) Method (Stream(TInput, Epoch), AutoRenamer(TIdentifier), Func(TInput, TIdentifier))
RenameUsing(TInput, TIdentifier) Method (Stream(TInput, Epoch), Stream(NodeWithValue(TIdentifier), Epoch), Func(TInput, TIdentifier))
RenameUsing(TInput, TIdentifier) Method (Stream(TInput, IterationIn(Epoch)), AutoRenamer(TIdentifier), Func(TInput, TIdentifier))
StateMachine Method
StateMachine(TValue, TState, TOutput, TTime) Method (Stream(NodeWithValue(TValue), TTime), Func(TValue, TState, Pair(TState, TOutput)))
StateMachine(TValue, TState, TTime) Method (Stream(NodeWithValue(TValue), TTime), Func(TValue, TState, TState))
StateMachine(TValue, TState, TOutput, TTime) Method (Stream(NodeWithValue(TValue), TTime), Func(TValue, TState, Pair(TState, TOutput)), TState)
StateMachine(TValue, TState, TTime) Method (Stream(NodeWithValue(TValue), TTime), Func(TValue, TState, TState), TState)
StateMachine(TValue, TState, TOutput, TTime) Method (Stream(NodeWithValue(TValue), TTime), Stream(NodeWithValue(TState), TTime), Func(TValue, TState, Pair(TState, TOutput)), TState)
TransmitAlong Method
TransmitAlong(TValue, TTime) Method (Stream(NodeWithValue(TValue), TTime), Stream(Edge, TTime))
TransmitAlong(TValue, TOutput, TTime) Method (Stream(NodeWithValue(TValue), TTime), Stream(Edge, TTime), Func(NodeWithValue(TValue), Node, TOutput))
Node Structure
Node Constructor
Node Fields
index Field
Node Methods
Equals Method
GetHashCode Method
ToString Method
WithValue(TValue) Method
Node Type Conversions
Implicit Conversion (Node to Int32)
NodeWithValue(TValue) Structure
NodeWithValue(TValue) Constructor
NodeWithValue(TValue) Fields
node Field
value Field
NodeWithValue(TValue) Methods
GetHashCode Method
Microsoft.Research.Naiad.Frameworks.Hdfs
ExtensionMethods Class
ExtensionMethods Methods
FromHdfs(TOutput, TTime) Method
FromHdfsBinary(TOutput, TTime) Method
FromHdfsText(TTime) Method
ReadHdfsBinaryCollection(TOutput) Method
ReadHdfsCollection(TOutput) Method
ReadHdfsTextCollection Method
ToHdfsBinary Method
ToHdfsBinary(TOutput, TTime) Method (Stream(TOutput, TTime), Uri, Int32, Int64, Int64)
ToHdfsBinary(TOutput, TWriter, TTime) Method (Stream(TOutput, TTime), Func(Int32, Int32, TTime, Int32, Uri), Func(Stream, TWriter), Action(TWriter, ArraySegment(TOutput)), Int32, Int64, Int64)
ToHdfsText(TTime) Method
WriteHdfsBinary Method
WriteHdfsBinary(TOutput) Method (Stream(TOutput, Epoch), Uri, Int32, Int64, Int64)
WriteHdfsBinary(TOutput, TWriter) Method (Stream(TOutput, Epoch), Func(Int32, Int32, Int32, Uri), Func(Stream, TWriter), Action(TWriter, ArraySegment(TOutput)), Int32, Int64, Int64)
WriteHdfsText Method
Microsoft.Research.Naiad.Frameworks.Lindi
ExtensionMethods Class
ExtensionMethods Methods
Aggregate Method
Aggregate(TKey, TState, TTime) Method (Stream(Pair(TKey, TState), TTime), Func(TState, TState, TState))
Aggregate(TKey, TState, TTime) Method (Stream(Pair(TKey, TState), TTime), Func(TState, TState, TState), Boolean)
Aggregate(TInput, TKey, TState, TOutput, TTime) Method (Stream(TInput, TTime), Func(TInput, TKey), Func(TInput, TState), Func(TState, TState, TState), Func(TKey, TState, TOutput))
Aggregate(TInput, TKey, TState, TOutput, TTime) Method (Stream(TInput, TTime), Func(TInput, TKey), Func(TInput, TState), Func(TState, TState, TState), Func(TKey, TState, TOutput), Boolean)
CoGroupBy(TInput1, TInput2, TKey, TOutput, TTime) Method
Concat(TRecord, TTime) Method
Count(TRecord, TTime) Method
Distinct(TRecord, TTime) Method
Except(TRecord, TTime) Method
GroupBy(TInput, TKey, TOutput, TTime) Method
Intersect(TRecord, TTime) Method
Join(TInput1, TInput2, TKey, TOutput, TTime) Method
Max(TInput, TKey, TValue, TTime) Method
Min(TInput, TKey, TValue, TTime) Method
Select(TInput, TOutput, TTime) Method
SelectMany(TInput, TOutput, TTime) Method
Union(TRecord, TTime) Method
Where(TRecord, TTime) Method
NonStandardExtensionMethods Class
NonStandardExtensionMethods Methods
Iterate Method
Iterate(TRecord, TTime) Method (Stream(TRecord, TTime), Func(LoopContext(TTime), Stream(TRecord, IterationIn(TTime)), Stream(TRecord, IterationIn(TTime))), Int32, String)
Iterate(TRecord, TTime) Method (Stream(TRecord, TTime), Func(LoopContext(TTime), Stream(TRecord, IterationIn(TTime)), Stream(TRecord, IterationIn(TTime))), Expression(Func(TRecord, Int32)), Int32, String)
Iterate(TRecord, TTime) Method (Stream(TRecord, TTime), Func(LoopContext(TTime), Stream(TRecord, IterationIn(TTime)), Stream(TRecord, IterationIn(TTime))), Func(TRecord, Int32), Expression(Func(TRecord, Int32)), Int32, String)
IterateAndAccumulate Method
IterateAndAccumulate(TRecord, TTime) Method (Stream(TRecord, TTime), Func(LoopContext(TTime), Stream(TRecord, IterationIn(TTime)), Stream(TRecord, IterationIn(TTime))), Int32, String)
IterateAndAccumulate(TRecord, TTime) Method (Stream(TRecord, TTime), Func(LoopContext(TTime), Stream(TRecord, IterationIn(TTime)), Stream(TRecord, IterationIn(TTime))), Expression(Func(TRecord, Int32)), Int32, String)
IterateAndAccumulate(TRecord, TTime) Method (Stream(TRecord, TTime), Func(LoopContext(TTime), Stream(TRecord, IterationIn(TTime)), Stream(TRecord, IterationIn(TTime))), Func(TRecord, Int32), Expression(Func(TRecord, Int32)), Int32, String)
SelectByVertex(TInput, TOutput, TTime) Method
SelectManyArraySegment(TInput, TOutput, TTime) Method
Synchronize(TRecord, TTime) Method
WriteToFiles(TInput) Method
Microsoft.Research.Naiad.Frameworks.Storage
Utils Class
Utils Methods
DefaultPartFormat Method
DefaultPartFormat Method (Uri, Int32, Int32, Int32)
DefaultPartFormat(TTime) Method (Uri, Int32, Int32, TTime, Int32)
GetNaiadReaderBatchEnumerable(TRecord) Method
GetNaiadReaderEnumerable(TRecord) Method
GetNaiadWriterObserver(TRecord) Method
ReadLines Method
WriteBySubscription(TOutput, TWriter) Method
WriteByTime(TOutput, TClient, TWriter, TTime) Method
Utils.FStreamWriter Class
Utils.FStreamWriter Constructor
Microsoft.Research.Naiad.Frameworks.Storage.Dfs
DfsBaseCoordinator(TWorkDescription) Class
DfsBaseCoordinator(TWorkDescription) Constructor
DfsBaseCoordinator(TWorkDescription) Fields
client Field
DfsBaseCoordinator(TWorkDescription) Methods
EnumerateFileWork Method
EnumerateWork Method
MapWorkerToQueue Method
NotifyQueueAddition Method
NotifyQueueRemoval Method
DfsBlock Class
DfsBlock Constructor
DfsBlock Fields
dataNodeAddress Field
fileLength Field
length Field
offset Field
path Field
DfsBlockCoordinator(TItem) Class
DfsBlockCoordinator(TItem) Constructor
DfsBlockCoordinator(TItem) Fields
DfsBlockCoordinator(TItem) Methods
EnumerateFileWork Method
ExpandWorkItem Method
MakeBaseMatches Method
DfsBlockWorker(TItem, TOutput) Class
DfsBlockWorker(TItem, TOutput) Constructor
DfsBlockWorker(TItem, TOutput) Fields
client Field
DfsBlockWorker(TItem, TOutput) Methods
DescribeWorker Method
DoWork Method
DfsFileCoordinator Class
DfsFileCoordinator Constructor
DfsFileCoordinator Fields
DfsFileCoordinator Methods
EnumerateFileWork Method
ExpandWorkItem Method
DfsFileWorker(TOutput) Class
DfsFileWorker(TOutput) Constructor
DfsFileWorker(TOutput) Fields
client Field
DfsFileWorker(TOutput) Methods
DescribeWorker Method
DoWork Method
DfsTextCoordinator Class
DfsTextCoordinator Constructor
DfsTextCoordinator Fields
DfsTextCoordinator Methods
MakeBaseMatches Method
DfsTextWorker Class
DfsTextWorker Constructor
DfsTextWorker Fields
DfsTextWorker Methods
Microsoft.Research.Naiad.Frameworks.WebHdfs
ExtensionMethods Class
ExtensionMethods Methods
FromWebHdfs Method
FromWebHdfs(TOutput, TTime) Method (Stream(Uri, TTime), Func(Stream, IEnumerable(ArraySegment(TOutput))))
FromWebHdfs(TOutput, TTime) Method (Stream(Uri, TTime), Func(Stream, IEnumerable(ArraySegment(TOutput))), String, Int32)
FromWebHdfsBinary Method
FromWebHdfsBinary(TOutput, TTime) Method (Stream(Uri, TTime))
FromWebHdfsBinary(TOutput, TTime) Method (Stream(Uri, TTime), String, Int32)
FromWebHdfsText Method
FromWebHdfsText(TTime) Method (Stream(Uri, TTime))
FromWebHdfsText(TTime) Method (Stream(Uri, TTime), String, Int32)
ReadWebHdfsBinaryCollection Method
ReadWebHdfsBinaryCollection(TOutput) Method (Computation, Uri)
ReadWebHdfsBinaryCollection(TOutput) Method (Computation, Uri, String, Int32)
ReadWebHdfsCollection Method
ReadWebHdfsCollection(TOutput) Method (Computation, Uri, Func(Stream, IEnumerable(ArraySegment(TOutput))))
ReadWebHdfsCollection(TOutput) Method (Computation, Uri, Func(Stream, IEnumerable(ArraySegment(TOutput))), String, Int32)
ReadWebHdfsTextCollection Method
ReadWebHdfsTextCollection Method (Computation, Uri)
ReadWebHdfsTextCollection Method (Computation, Uri, String, Int32)
ToWebHdfsBinary Method
ToWebHdfsBinary(TOutput, TTime) Method (Stream(TOutput, TTime), String, Int32, Uri, Int32, Int64, Int64)
ToWebHdfsBinary(TOutput, TWriter, TTime) Method (Stream(TOutput, TTime), String, Int32, Func(Int32, Int32, TTime, Int32, Uri), Func(Stream, TWriter), Action(TWriter, ArraySegment(TOutput)), Int64, Int64)
ToWebHdfsText(TTime) Method
WriteWebHdfsBinary Method
WriteWebHdfsBinary(TOutput) Method (Stream(TOutput, Epoch), String, Int32, Uri, Int32, Int64, Int64)
WriteWebHdfsBinary(TOutput, TWriter) Method (Stream(TOutput, Epoch), String, Int32, Func(Int32, Int32, Int32, Uri), Func(Stream, TWriter), Action(TWriter, ArraySegment(TOutput)), Int64, Int64)
WriteWebHdfsText Method
Microsoft.Research.Naiad.Frameworks.WorkGenerator
ExtensionMethods Class
ExtensionMethods Methods
GenerateWork(TInput, TWorkDescription, TWorkerDescription, TOutput, TTime) Method
ICoordinator(TInput, TWorkDescription, TWorkerDescription) Interface
ICoordinator(TInput, TWorkDescription, TWorkerDescription) Methods
AddInput Method
AssignWork Method
IWorker(TWorkDescription, TWorkerDescription, TOutput) Interface
IWorker(TWorkDescription, TWorkerDescription, TOutput) Methods
DescribeWorker Method
DoWork Method
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription) Class
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription) Constructor
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription) Fields
waitingWork Field
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription) Methods
AddInput Method
AssignWork Method
EnumerateWork Method
ExpandWorkItem Method
MapWorkerToQueue Method
NotifyQueueAddition Method
NotifyQueueRemoval Method
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription).Match Class
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription).Match Constructor
Match Fields
categories Field
workStub Field
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription).MatchQueue Class
MatchingCoordinator(TInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescription).MatchQueue Constructor
MatchQueue Methods
Compare Method
Dequeue Method
Enqueue Method
MarkTaken Method
MatchQueue Properties
Count Property
WorkItem(TWorkDescription) Structure
WorkItem(TWorkDescription) Fields
description Field
destination Field
type Field
WorkRecordType Enumeration
WorkRequest(TWorkerDescription) Structure
WorkRequest(TWorkerDescription) Fields
description Field
source Field
Microsoft.Research.Naiad.Input
BaseDataSource(TRecord) Class
BaseDataSource(TRecord) Constructor
BaseDataSource(TRecord) Fields
inputsByWorker Field
BaseDataSource(TRecord) Methods
Activate Method
Join Method
RegisterInputs Method
BatchedDataSource(TRecord) Class
BatchedDataSource(TRecord) Constructor
BatchedDataSource(TRecord) Fields
BatchedDataSource(TRecord) Methods
Join Method
OnCompleted Method
OnCompleted Method
OnCompleted Method (IEnumerable(TRecord))
OnCompleted Method (TRecord)
OnError Method
OnNext Method
OnNext Method
OnNext Method (IEnumerable(TRecord))
OnNext Method (TRecord)
ConstantDataSource(TRecord) Class
ConstantDataSource(TRecord) Constructor
ConstantDataSource(TRecord) Constructor
ConstantDataSource(TRecord) Constructor (IEnumerable(TRecord))
ConstantDataSource(TRecord) Constructor (TRecord)
ConstantDataSource(TRecord) Fields
ConstantDataSource(TRecord) Methods
Activate Method
DataSource Interface
DataSource Methods
Activate Method
Join Method
DataSource(TRecord) Interface
DataSource(TRecord) Methods
RegisterInputs Method
DataSourceExtensionMethods Class
DataSourceExtensionMethods Methods
AsNaiadStream Method
AsNaiadStream(TRecord) Method (IEnumerable(TRecord), Computation)
AsNaiadStream(TRecord) Method (IObservable(IEnumerable(TRecord)), Computation)
InterGraphDataSink(TRecord) Class
InterGraphDataSink(TRecord) Constructor
InterGraphDataSink(TRecord) Methods
NewDataSource Method
Seal Method
InterGraphDataSource(TRecord) Class
InterGraphDataSource(TRecord) Constructor
InterGraphDataSource(TRecord) Fields
InterGraphDataSource(TRecord) Methods
Activate Method
OnCompleted Method
OnNotify Method
OnRecv Method
Microsoft.Research.Naiad.Runtime.Progress
Pointstamp Structure
Pointstamp Fields
Location Field
Timestamp Field
Pointstamp Methods
Equals Method
GetHashCode Method
ToString Method
Pointstamp.FakeArray Structure
Pointstamp.FakeArray Constructor
FakeArray Fields
a Field
b Field
c Field
d Field
Length Field
spillover Field
FakeArray Methods
ToString Method
FakeArray Properties
Item Property
Update Structure
Update Fields
Delta Field
Pointstamp Field
Microsoft.Research.Naiad.Serialization
AutoSerialization Class
CheckpointRestoreExtensionMethods Class
CheckpointRestoreExtensionMethods Methods
Checkpoint Method
Checkpoint(TKey, TValue) Method (Dictionary(TKey, TValue), NaiadWriter)
Checkpoint(TElement) Method (List(TElement), NaiadWriter)
Checkpoint(TElement) Method (TElement[], Int32, NaiadWriter)
Restore Method
Restore(TKey, TValue) Method (Dictionary(TKey, TValue), NaiadReader)
Restore(TElement) Method (List(TElement), NaiadReader)
RestoreArray(TElement) Method
CustomSerialization Class
CustomSerialization Methods
MakeSerializer Method
MakeSerializer(TElement, TCustomSerialization) Method
MakeSerializer(TElement, TCustomSerialization) Method (TCustomSerialization)
CustomSerialization(TElement) Interface
CustomSerialization(TElement) Methods
Deserialize Method
TrySerialize Method
Deserializers Class
Deserializers Methods
TryDeserialize Method
TryDeserialize Method (RecvBuffer, Boolean)
TryDeserialize Method (RecvBuffer, Byte)
TryDeserialize Method (RecvBuffer, Byte[])
TryDeserialize Method (RecvBuffer, Char)
TryDeserialize Method (RecvBuffer, Double)
TryDeserialize Method (RecvBuffer, Int16)
TryDeserialize Method (RecvBuffer, Int32)
TryDeserialize Method (RecvBuffer, Int32[])
TryDeserialize Method (RecvBuffer, Int64)
TryDeserialize Method (RecvBuffer, Single)
TryDeserialize Method (RecvBuffer, Single[])
TryDeserialize Method (RecvBuffer, String)
TryDeserialize Method (RecvBuffer, UInt32)
TryDeserialize Method (RecvBuffer, UInt64)
IFlushable Interface
IFlushable Methods
Flush Method
MessageHeader Structure
MessageHeader Fields
ChannelID Field
DestVertexID Field
FromVertexID Field
Length Field
SequenceNumber Field
Type Field
MessageHeader Properties
Serialization Property
NaiadReader Class
NaiadReader Constructor
NaiadReader Methods
Dispose Method
Read Method
Read(TElement) Method
Read(TElement) Method (NaiadSerialization(TElement))
TryRead(TElement) Method
NaiadReader(TElement) Class
NaiadReader(TElement) Constructor
NaiadReader(TElement) Methods
Dispose Method
Read Method
TryRead Method
TryReadMany Method
NaiadSerialization(TElement) Interface
NaiadSerialization(TElement) Methods
Serialize Method
TryDeserialize Method
TryDeserializeMany Method
TrySerializeMany Method
NaiadWriter Class
NaiadWriter Constructor
NaiadWriter Methods
Dispose Method
Flush Method
Write Method
Write(TElement) Method (TElement)
Write(TElement) Method (TElement, NaiadSerialization(TElement))
NaiadWriter(TElement) Class
NaiadWriter(TElement) Constructor
NaiadWriter(TElement) Methods
Dispose Method
Flush Method
Write Method
RecvBuffer Structure
RecvBuffer Fields
Buffer Field
CurrentPos Field
End Field
RecvBuffer Properties
Available Property
SerializationFormat Interface
SerializationFormat Methods
GetSerializationForMinorVersion(TElement) Method
GetSerializer(TElement) Method
RegisterCustomSerialization(TElement, TSerializer) Method
SerializationFormat Properties
MajorVersion Property
MinorVersion Property
SerializedMessage Class
SerializedMessage Fields
Body Field
SerializedMessage Methods
Dispose Method
SerializedMessageType Enumeration
Serializers Class
Serializers Methods
Serialize Method
Serialize Method (SubArray(Byte), Boolean)
Serialize Method (SubArray(Byte), Byte)
Serialize Method (SubArray(Byte), Byte[])
Serialize Method (SubArray(Byte), Double)
Serialize Method (SubArray(Byte), Int16)
Serialize Method (SubArray(Byte), Int32)
Serialize Method (SubArray(Byte), Int32[])
Serialize Method (SubArray(Byte), Int64)
Serialize Method (SubArray(Byte), Single)
Serialize Method (SubArray(Byte), Single[])
Serialize Method (SubArray(Byte), String)
Serialize Method (SubArray(Byte), UInt32)
Serialize Method (SubArray(Byte), UInt64)
SubArray(TElement) Structure
SubArray(TElement) Constructor
SubArray(TElement) Constructor (TElement[])
SubArray(TElement) Constructor (TElement[], Int32)
SubArray(TElement) Fields
Array Field
Count Field
SubArray(TElement) Methods
EnsureAvailable Method
SubArray(TElement) Properties
Available Property
Item Property
Length Property
Microsoft.Research.Naiad.Utilities
ExpressionComparer Class
ExpressionComparer Constructor
ExpressionComparer Methods
Equals Method
ExpressionComparer Properties
Instance Property
This page uses an IFRAME but your browser does not support it.