OneOffComputation MethodsNaiad Help

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

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
See Also

Reference