OneOffComputation InterfaceNaiad Help

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

A Computation with an internal Controller which cannot be re-used for other Computations.

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 OneOffComputation : Computation, 
	IDisposable

The OneOffComputation type exposes the following members.

Methods

  NameDescription
Public methodCode exampleActivate
Starts computation in this graph.
(Inherited from Computation.)
Public methodCode exampleJoin
Blocks until all computation in this graph has termintaed.
(Inherited from Computation.)
Public methodNewInputTRecord(DataSourceTRecord)
Creates a new input stage from the given DataSource.
(Inherited from Computation.)
Public methodNewInputTRecord(DataSourceTRecord, String)
Creates a new input stage from the given DataSource.
(Inherited from Computation.)
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.
(Inherited from Computation.)
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 propertyConfiguration
The configuration used by this controller.
Public propertyController
The Controller that hosts this graph.
(Inherited from Computation.)
Public propertyDefaultPlacement
The default placement of new stages.
Public propertyWorkerGroup
The workers associated with this controller.
Top
Events

  NameDescription
Public eventCode exampleOnFrontierChange
An event that is raised each time the frontier changes.
(Inherited from Computation.)
Public eventOnShutdown
An event that is raised once the graph is shut down.
(Inherited from Computation.)
Public eventOnStartup
An event that is raised once the graph is started.
(Inherited from Computation.)
Top
See Also

Reference