Computation InterfaceNaiad Help

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

Manages the construction and execution of an individual dataflow computation.

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

C#
public interface Computation : IDisposable

The Computation type exposes the following members.

Methods

  NameDescription
Public methodCode exampleActivate
Starts computation in this graph.
Public methodCode exampleJoin
Blocks until all computation in this graph has termintaed.
Public methodNewInput<TRecord>(DataSource<TRecord>)
Creates a new input stage from the given DataSource.
Public methodNewInput<TRecord>(DataSource<TRecord>, String)
Creates a new input stage from the given DataSource.
Public methodCode exampleSync
Blocks until all subscriptions have processed all inputs up to the supplied epoch. If the computation has no subscriptions, no synchronization occurs.
Top
Extension Methods

  NameDescription
Public Extension MethodDefaultAccount
Returns the default CloudStorageAccount for this computation.
(Defined by ExtensionMethods.)
Public Extension MethodDefaultBlobContainer
Returns a reference to the CloudBlobContainer with the given containerName in the default account for this computation. The container will be created if it does not exist.
(Defined by ExtensionMethods.)
Public Extension MethodNewInputCollection<TRecord> (Defined by InputCollectionExtensionMethods.)
Public Extension MethodReadBinaryFromAzureBlobs<TRecord>
Reads the contents of all files in an Azure directory into a Naiad stream. The serialization format is the same as WriteBinaryToAzureBlobs, and based on the Naiad message format.
(Defined by ExtensionMethods.)
Public Extension MethodReadCustomBinaryFromAzureBlobs<R>
Reads the contents of all binary files in an Azure directory into a Naiad stream.
(Defined by ExtensionMethods.)
Public Extension MethodReadFromAzureBlobs<TRecord>
Reads the contents of all files in an Azure directory into a Naiad stream.
(Defined by ExtensionMethods.)
Public Extension MethodReadFromAzureTable<TEntity>
Reads the entities from the given Azure table, filtered by the given query.
(Defined by ExtensionMethods.)
Public Extension MethodReadHdfsBinaryCollection<TOutput>
Read a collection of HDFS files serialized in the default Naiad binary format. Concatenate all the records to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadHdfsCollection<TOutput>
Read a collection of HDFS files serialized in a custom binary format. Concatenate all the records to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadHdfsTextCollection
Read a collection of HDFS files serialized as lines of text. Concatenate all the lines of the files to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadTextFromAzureBlobs
Reads the contents of all text files in an Azure directory into a Naiad stream.
(Defined by ExtensionMethods.)
Public Extension MethodReadWebHdfsBinaryCollection<TOutput>(Uri)Overloaded.
Read a collection of HDFS files serialized in the default Naiad binary format. Concatenate all the records to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadWebHdfsBinaryCollection<TOutput>(Uri, String, Int32)Overloaded.
Read a collection of HDFS files serialized in the default Naiad binary format. Concatenate all the records to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadWebHdfsCollection<TOutput>(Uri, Func<Stream, IEnumerable<ArraySegment<TOutput>>>)Overloaded.
Read a collection of HDFS files serialized in a custom binary format. Concatenate all the records to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadWebHdfsCollection<TOutput>(Uri, Func<Stream, IEnumerable<ArraySegment<TOutput>>>, String, Int32)Overloaded.
Read a collection of HDFS files serialized in a custom binary format. Concatenate all the records to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadWebHdfsTextCollection(Uri)Overloaded.
Read a collection of HDFS files serialized as lines of text. Concatenate all the lines of the files to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Public Extension MethodReadWebHdfsTextCollection(Uri, String, Int32)Overloaded.
Read a collection of HDFS files serialized as lines of text. Concatenate all the lines of the files to the output, in an unspecified order.
(Defined by ExtensionMethods.)
Top
Properties

  NameDescription
Public propertyController
The Controller that hosts this graph.
Top
Events

  NameDescription
Public eventCode exampleOnFrontierChange
An event that is raised each time the frontier changes.
Public eventOnShutdown
An event that is raised once the graph is shut down.
Public eventOnStartup
An event that is raised once the graph is started.
Top
Remarks

A Computation manages the execution of a single Naiad computation. To construct an instance of this interface, use the NewComputation() method.
See Also

Reference