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 methodNewInputTRecord(DataSourceTRecord)
Creates a new input stage from the given DataSource.
Public methodNewInputTRecord(DataSourceTRecord, 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 MethodNewInputCollectionTRecord (Defined by InputCollectionExtensionMethods.)
Public Extension MethodReadBinaryFromAzureBlobsTRecord
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 MethodReadCustomBinaryFromAzureBlobsR
Reads the contents of all binary files in an Azure directory into a Naiad stream.
(Defined by ExtensionMethods.)
Public Extension MethodReadFromAzureBlobsTRecord
Reads the contents of all files in an Azure directory into a Naiad stream.
(Defined by ExtensionMethods.)
Public Extension MethodReadFromAzureTableTEntity
Reads the entities from the given Azure table, filtered by the given query.
(Defined by ExtensionMethods.)
Public Extension MethodReadHdfsBinaryCollectionTOutput
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 MethodReadHdfsCollectionTOutput
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 MethodReadWebHdfsBinaryCollectionTOutput(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 MethodReadWebHdfsBinaryCollectionTOutput(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 MethodReadWebHdfsCollectionTOutput(Uri, FuncStream, IEnumerableArraySegmentTOutput)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 MethodReadWebHdfsCollectionTOutput(Uri, FuncStream, IEnumerableArraySegmentTOutput, 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