Share via


StreamAnalytics Class

Definition

Low-level API implementation for the StreamAnalytics service.

public class StreamAnalytics
type StreamAnalytics = class
Public Class StreamAnalytics
Inheritance
StreamAnalytics

Constructors

StreamAnalytics()

Methods

ClustersCreateOrUpdate(String, String, String, String, String, ICluster, Func<HttpResponseMessage,Task<ICluster>,Task>, Func<HttpResponseMessage, Task<IError>,Task>, IEventListener, ISendAsync)

Creates a Stream Analytics Cluster or replaces an already existing cluster.

ClustersCreateOrUpdateViaIdentity(String, String, String, ICluster, Func<HttpResponseMessage,Task<ICluster>,Task>, Func<HttpResponseMessage, Task<IError>,Task>, IEventListener, ISendAsync)

Creates a Stream Analytics Cluster or replaces an already existing cluster.

ClustersDelete(String, String, String, Func<HttpResponseMessage, Task>, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage, Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Deletes the specified cluster.

ClustersDeleteViaIdentity(String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Deletes the specified cluster.

ClustersGet(String, String, String, Func<HttpResponseMessage, Task<ICluster>,Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Gets information about the specified cluster.

ClustersGetViaIdentity(String, Func<HttpResponseMessage,Task<ICluster>, Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Gets information about the specified cluster.

ClustersListByResourceGroup(String, String, Func<HttpResponseMessage, Task<IClusterListResult>,Task>, Func<HttpResponseMessage,Task<IError>, Task>, IEventListener, ISendAsync)

Lists all of the clusters in the given resource group.

ClustersListByResourceGroupViaIdentity(String, Func<HttpResponseMessage, Task<IClusterListResult>,Task>, Func<HttpResponseMessage,Task<IError>, Task>, IEventListener, ISendAsync)

Lists all of the clusters in the given resource group.

ClustersListBySubscription(String, Func<HttpResponseMessage,Task<IClusterListResult>, Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Lists all of the clusters in the given subscription.

ClustersListBySubscriptionViaIdentity(String, Func<HttpResponseMessage, Task<IClusterListResult>,Task>, Func<HttpResponseMessage,Task<IError>, Task>, IEventListener, ISendAsync)

Lists all of the clusters in the given subscription.

ClustersListStreamingJobs(String, String, String, Func<HttpResponseMessage, Task<IClusterJobListResult>,Task>, Func<HttpResponseMessage,Task<IError>, Task>, IEventListener, ISendAsync)

Lists all of the streaming jobs in the given cluster.

ClustersListStreamingJobsViaIdentity(String, Func<HttpResponseMessage, Task<IClusterJobListResult>,Task>, Func<HttpResponseMessage,Task<IError>, Task>, IEventListener, ISendAsync)

Lists all of the streaming jobs in the given cluster.

ClustersUpdate(String, String, String, String, ICluster, Func<HttpResponseMessage, Task<ICluster>,Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Updates an existing cluster. This can be used to partially update (ie. update one or two properties) a cluster without affecting the rest of the cluster definition.

ClustersUpdateViaIdentity(String, String, ICluster, Func<HttpResponseMessage, Task<ICluster>,Task>, Func<HttpResponseMessage,Task<IError>,Task>, IEventListener, ISendAsync)

Updates an existing cluster. This can be used to partially update (ie. update one or two properties) a cluster without affecting the rest of the cluster definition.

FunctionsCreateOrReplace(String, String, String, String, String, String, IFunction, Func<HttpResponseMessage,Task<IFunction>, Task>, Func<HttpResponseMessage,Task<IFunction>,Task>, IEventListener, ISendAsync)

Creates a function or replaces an already existing function under an existing streaming job.

FunctionsCreateOrReplaceViaIdentity(String, String, String, IFunction, Func<HttpResponseMessage,Task<IFunction>,Task>, Func<HttpResponseMessage, Task<IFunction>,Task>, IEventListener, ISendAsync)

Creates a function or replaces an already existing function under an existing streaming job.

FunctionsDelete(String, String, String, String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes a function from the streaming job.

FunctionsDeleteViaIdentity(String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes a function from the streaming job.

FunctionsGet(String, String, String, String, Func<HttpResponseMessage,Task<IFunction>,Task>, IEventListener, ISendAsync)

Gets details about the specified function.

FunctionsGetViaIdentity(String, Func<HttpResponseMessage,Task<IFunction>,Task>, IEventListener, ISendAsync)

Gets details about the specified function.

FunctionsListByStreamingJob(String, String, String, String, Func<HttpResponseMessage,Task<IFunctionListResult>,Task>, IEventListener, ISendAsync)

Lists all of the functions under the specified streaming job.

FunctionsListByStreamingJobViaIdentity(String, String, Func<HttpResponseMessage,Task<IFunctionListResult>,Task>, IEventListener, ISendAsync)

Lists all of the functions under the specified streaming job.

FunctionsRetrieveDefaultDefinition(String, String, String, String, IFunctionRetrieveDefaultDefinitionParameters, Func<HttpResponseMessage, Task<IFunction>,Task>, IEventListener, ISendAsync)

Retrieves the default definition of a function based on the parameters specified.

FunctionsRetrieveDefaultDefinitionViaIdentity(String, IFunctionRetrieveDefaultDefinitionParameters, Func<HttpResponseMessage,Task<IFunction>,Task>, IEventListener, ISendAsync)

Retrieves the default definition of a function based on the parameters specified.

FunctionsTest(String, String, String, String, IFunction, Func<HttpResponseMessage,Task<IResourceTestStatus>,Task>, IEventListener, ISendAsync)

Tests if the information provided for a function is valid. This can range from testing the connection to the underlying web service behind the function or making sure the function code provided is syntactically correct.

FunctionsTestViaIdentity(String, IFunction, Func<HttpResponseMessage,Task<IResourceTestStatus>,Task>, IEventListener, ISendAsync)

Tests if the information provided for a function is valid. This can range from testing the connection to the underlying web service behind the function or making sure the function code provided is syntactically correct.

FunctionsUpdate(String, String, String, String, String, IFunction, Func<HttpResponseMessage,Task<IFunction>,Task>, IEventListener, ISendAsync)

Updates an existing function under an existing streaming job. This can be used to partially update (ie. update one or two properties) a function without affecting the rest the job or function definition.

FunctionsUpdateViaIdentity(String, String, IFunction, Func<HttpResponseMessage,Task<IFunction>,Task>, IEventListener, ISendAsync)

Updates an existing function under an existing streaming job. This can be used to partially update (ie. update one or two properties) a function without affecting the rest the job or function definition.

InputsCreateOrReplace(String, String, String, String, String, String, IInput, Func<HttpResponseMessage,Task<IInput>,Task>, Func<HttpResponseMessage,Task<IInput>,Task>, IEventListener, ISendAsync)

Creates an input or replaces an already existing input under an existing streaming job.

InputsCreateOrReplaceViaIdentity(String, String, String, IInput, Func<HttpResponseMessage,Task<IInput>,Task>, Func<HttpResponseMessage, Task<IInput>,Task>, IEventListener, ISendAsync)

Creates an input or replaces an already existing input under an existing streaming job.

InputsDelete(String, String, String, String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes an input from the streaming job.

InputsDeleteViaIdentity(String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes an input from the streaming job.

InputsGet(String, String, String, String, Func<HttpResponseMessage,Task<IInput>,Task>, IEventListener, ISendAsync)

Gets details about the specified input.

InputsGetViaIdentity(String, Func<HttpResponseMessage,Task<IInput>,Task>, IEventListener, ISendAsync)

Gets details about the specified input.

InputsListByStreamingJob(String, String, String, String, Func<HttpResponseMessage,Task<IInputListResult>,Task>, IEventListener, ISendAsync)

Lists all of the inputs under the specified streaming job.

InputsListByStreamingJobViaIdentity(String, String, Func<HttpResponseMessage,Task<IInputListResult>,Task>, IEventListener, ISendAsync)

Lists all of the inputs under the specified streaming job.

InputsTest(String, String, String, String, IInput, Func<HttpResponseMessage,Task<IResourceTestStatus>,Task>, IEventListener, ISendAsync)

Tests whether an input’s datasource is reachable and usable by the Azure Stream Analytics service.

InputsTestViaIdentity(String, IInput, Func<HttpResponseMessage,Task<IResourceTestStatus>,Task>, IEventListener, ISendAsync)

Tests whether an input’s datasource is reachable and usable by the Azure Stream Analytics service.

InputsUpdate(String, String, String, String, String, IInput, Func<HttpResponseMessage,Task<IInput>,Task>, IEventListener, ISendAsync)

Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.

InputsUpdateViaIdentity(String, String, IInput, Func<HttpResponseMessage,Task<IInput>,Task>, IEventListener, ISendAsync)

Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.

OperationsList(Func<HttpResponseMessage,Task<IOperationListResult>,Task>, IEventListener, ISendAsync)

Lists all of the available Stream Analytics related operations.

OperationsListViaIdentity(String, Func<HttpResponseMessage,Task<IOperationListResult>,Task>, IEventListener, ISendAsync)

Lists all of the available Stream Analytics related operations.

OutputsCreateOrReplace(String, String, String, String, String, String, IOutput, Func<HttpResponseMessage,Task<IOutput>,Task>, Func<HttpResponseMessage,Task<IOutput>,Task>, IEventListener, ISendAsync)

Creates an output or replaces an already existing output under an existing streaming job.

OutputsCreateOrReplaceViaIdentity(String, String, String, IOutput, Func<HttpResponseMessage,Task<IOutput>,Task>, Func<HttpResponseMessage, Task<IOutput>,Task>, IEventListener, ISendAsync)

Creates an output or replaces an already existing output under an existing streaming job.

OutputsDelete(String, String, String, String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes an output from the streaming job.

OutputsDeleteViaIdentity(String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes an output from the streaming job.

OutputsGet(String, String, String, String, Func<HttpResponseMessage,Task<IOutput>,Task>, IEventListener, ISendAsync)

Gets details about the specified output.

OutputsGetViaIdentity(String, Func<HttpResponseMessage,Task<IOutput>,Task>, IEventListener, ISendAsync)

Gets details about the specified output.

OutputsListByStreamingJob(String, String, String, String, Func<HttpResponseMessage,Task<IOutputListResult>,Task>, IEventListener, ISendAsync)

Lists all of the outputs under the specified streaming job.

OutputsListByStreamingJobViaIdentity(String, String, Func<HttpResponseMessage,Task<IOutputListResult>,Task>, IEventListener, ISendAsync)

Lists all of the outputs under the specified streaming job.

OutputsTest(String, String, String, String, IOutput, Func<HttpResponseMessage,Task<IResourceTestStatus>,Task>, IEventListener, ISendAsync)

Tests whether an output’s datasource is reachable and usable by the Azure Stream Analytics service.

OutputsTestViaIdentity(String, IOutput, Func<HttpResponseMessage,Task<IResourceTestStatus>,Task>, IEventListener, ISendAsync)

Tests whether an output’s datasource is reachable and usable by the Azure Stream Analytics service.

OutputsUpdate(String, String, String, String, String, IOutput, Func<HttpResponseMessage,Task<IOutput>,Task>, IEventListener, ISendAsync)

Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.

OutputsUpdateViaIdentity(String, String, IOutput, Func<HttpResponseMessage,Task<IOutput>,Task>, IEventListener, ISendAsync)

Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.

StreamingJobsCreateOrReplace(String, String, String, String, String, IStreamingJob, Func<HttpResponseMessage,Task<IStreamingJob>, Task>, IEventListener, ISendAsync)

Creates a streaming job or replaces an already existing streaming job.

StreamingJobsCreateOrReplaceViaIdentity(String, String, String, IStreamingJob, Func<HttpResponseMessage,Task<IStreamingJob>, Task>, IEventListener, ISendAsync)

Creates a streaming job or replaces an already existing streaming job.

StreamingJobsDelete(String, String, String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes a streaming job.

StreamingJobsDeleteViaIdentity(String, Func<HttpResponseMessage,Task>, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Deletes a streaming job.

StreamingJobsGet(String, String, String, String, Func<HttpResponseMessage,Task<IStreamingJob>,Task>, IEventListener, ISendAsync)

Gets details about the specified streaming job.

StreamingJobsGetViaIdentity(String, String, Func<HttpResponseMessage,Task<IStreamingJob>,Task>, IEventListener, ISendAsync)

Gets details about the specified streaming job.

StreamingJobsList(String, String, Func<HttpResponseMessage,Task<IStreamingJobListResult>,Task>, IEventListener, ISendAsync)

Lists all of the streaming jobs in the given subscription.

StreamingJobsListByResourceGroup(String, String, String, Func<HttpResponseMessage,Task<IStreamingJobListResult>,Task>, IEventListener, ISendAsync)

Lists all of the streaming jobs in the specified resource group.

StreamingJobsListByResourceGroupViaIdentity(String, String, Func<HttpResponseMessage,Task<IStreamingJobListResult>,Task>, IEventListener, ISendAsync)

Lists all of the streaming jobs in the specified resource group.

StreamingJobsListViaIdentity(String, String, Func<HttpResponseMessage,Task<IStreamingJobListResult>,Task>, IEventListener, ISendAsync)

Lists all of the streaming jobs in the given subscription.

StreamingJobsStart(String, String, String, IStartStreamingJobParameters, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Starts a streaming job. Once a job is started it will start processing input events and produce output.

StreamingJobsStartViaIdentity(String, IStartStreamingJobParameters, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Starts a streaming job. Once a job is started it will start processing input events and produce output.

StreamingJobsStop(String, String, String, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Stops a running streaming job. This will cause a running streaming job to stop processing input events and producing output.

StreamingJobsStopViaIdentity(String, Func<HttpResponseMessage,Task>, IEventListener, ISendAsync)

Stops a running streaming job. This will cause a running streaming job to stop processing input events and producing output.

StreamingJobsUpdate(String, String, String, String, IStreamingJob, Func<HttpResponseMessage,Task<IStreamingJob>,Task>, IEventListener, ISendAsync)

Updates an existing streaming job. This can be used to partially update (ie. update one or two properties) a streaming job without affecting the rest the job definition.

StreamingJobsUpdateViaIdentity(String, String, IStreamingJob, Func<HttpResponseMessage,Task<IStreamingJob>,Task>, IEventListener, ISendAsync)

Updates an existing streaming job. This can be used to partially update (ie. update one or two properties) a streaming job without affecting the rest the job definition.

SubscriptionsListQuotas(String, String, Func<HttpResponseMessage,Task<ISubscriptionQuotasListResult>,Task>, IEventListener, ISendAsync)

Retrieves the subscription's current quota information in a particular region.

SubscriptionsListQuotasViaIdentity(String, Func<HttpResponseMessage,Task<ISubscriptionQuotasListResult>,Task>, IEventListener, ISendAsync)

Retrieves the subscription's current quota information in a particular region.

TransformationsCreateOrReplace(String, String, String, String, String, String, ITransformation, Func<HttpResponseMessage,Task<ITransformation>, Task>, Func<HttpResponseMessage,Task<ITransformation>,Task>, IEventListener, ISendAsync)

Creates a transformation or replaces an already existing transformation under an existing streaming job.

TransformationsCreateOrReplaceViaIdentity(String, String, String, ITransformation, Func<HttpResponseMessage,Task<ITransformation>, Task>, Func<HttpResponseMessage,Task<ITransformation>,Task>, IEventListener, ISendAsync)

Creates a transformation or replaces an already existing transformation under an existing streaming job.

TransformationsGet(String, String, String, String, Func<HttpResponseMessage,Task<ITransformation>,Task>, IEventListener, ISendAsync)

Gets details about the specified transformation.

TransformationsGetViaIdentity(String, Func<HttpResponseMessage,Task<ITransformation>,Task>, IEventListener, ISendAsync)

Gets details about the specified transformation.

TransformationsUpdate(String, String, String, String, String, ITransformation, Func<HttpResponseMessage,Task<ITransformation>, Task>, IEventListener, ISendAsync)

Updates an existing transformation under an existing streaming job. This can be used to partially update (ie. update one or two properties) a transformation without affecting the rest the job or transformation definition.

TransformationsUpdateViaIdentity(String, String, ITransformation, Func<HttpResponseMessage,Task<ITransformation>,Task>, IEventListener, ISendAsync)

Updates an existing transformation under an existing streaming job. This can be used to partially update (ie. update one or two properties) a transformation without affecting the rest the job or transformation definition.

Applies to