Interface ClustersClient
-
public interface ClustersClient
An instance of this class provides access to all the operations defined in ClustersClient.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner>
beginCreateOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch)
Creates a Stream Analytics Cluster or replaces an already existing cluster.com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner>
beginCreateOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch, com.azure.core.util.Context context)
Creates a Stream Analytics Cluster or replaces an already existing cluster.com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<Void>,Void>
beginDelete(String resourceGroupName, String clusterName)
Deletes the specified cluster.com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<Void>,Void>
beginDelete(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Deletes the specified cluster.com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner>
beginUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch)
Updates an existing cluster.com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner>
beginUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, com.azure.core.util.Context context)
Updates an existing cluster.ClusterInner
createOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster)
Creates a Stream Analytics Cluster or replaces an already existing cluster.ClusterInner
createOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch)
Creates a Stream Analytics Cluster or replaces an already existing cluster.ClusterInner
createOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch, com.azure.core.util.Context context)
Creates a Stream Analytics Cluster or replaces an already existing cluster.void
delete(String resourceGroupName, String clusterName)
Deletes the specified cluster.void
delete(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Deletes the specified cluster.ClusterInner
getByResourceGroup(String resourceGroupName, String clusterName)
Gets information about the specified cluster.com.azure.core.http.rest.Response<ClusterInner>
getByResourceGroupWithResponse(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Gets information about the specified cluster.com.azure.core.http.rest.PagedIterable<ClusterInner>
list()
Lists all of the clusters in the given subscription.com.azure.core.http.rest.PagedIterable<ClusterInner>
list(com.azure.core.util.Context context)
Lists all of the clusters in the given subscription.com.azure.core.http.rest.PagedIterable<ClusterInner>
listByResourceGroup(String resourceGroupName)
Lists all of the clusters in the given resource group.com.azure.core.http.rest.PagedIterable<ClusterInner>
listByResourceGroup(String resourceGroupName, com.azure.core.util.Context context)
Lists all of the clusters in the given resource group.com.azure.core.http.rest.PagedIterable<ClusterJobInner>
listStreamingJobs(String resourceGroupName, String clusterName)
Lists all of the streaming jobs in the given cluster.com.azure.core.http.rest.PagedIterable<ClusterJobInner>
listStreamingJobs(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Lists all of the streaming jobs in the given cluster.ClusterInner
update(String resourceGroupName, String clusterName, ClusterInner cluster)
Updates an existing cluster.ClusterInner
update(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch)
Updates an existing cluster.ClusterInner
update(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, com.azure.core.util.Context context)
Updates an existing cluster.
-
-
-
Method Detail
-
beginCreateOrUpdate
com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner> beginCreateOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch)
Creates a Stream Analytics Cluster or replaces an already existing cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The definition of the cluster that will be used to create a new cluster or replace the existing one.ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.ifNoneMatch
- Set to '*' to allow a new resource to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
beginCreateOrUpdate
com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner> beginCreateOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch, com.azure.core.util.Context context)
Creates a Stream Analytics Cluster or replaces an already existing cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The definition of the cluster that will be used to create a new cluster or replace the existing one.ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.ifNoneMatch
- Set to '*' to allow a new resource to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.context
- The context to associate with this operation.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
createOrUpdate
ClusterInner createOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch)
Creates a Stream Analytics Cluster or replaces an already existing cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The definition of the cluster that will be used to create a new cluster or replace the existing one.ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.ifNoneMatch
- Set to '*' to allow a new resource to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
createOrUpdate
ClusterInner createOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster)
Creates a Stream Analytics Cluster or replaces an already existing cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The definition of the cluster that will be used to create a new cluster or replace the existing one.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
createOrUpdate
ClusterInner createOrUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, String ifNoneMatch, com.azure.core.util.Context context)
Creates a Stream Analytics Cluster or replaces an already existing cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The definition of the cluster that will be used to create a new cluster or replace the existing one.ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.ifNoneMatch
- Set to '*' to allow a new resource to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.context
- The context to associate with this operation.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
beginUpdate
com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner> beginUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch)
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.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The properties specified here will overwrite the corresponding properties in the existing cluster (ie. Those properties will be updated).ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
beginUpdate
com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<ClusterInner>,ClusterInner> beginUpdate(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, com.azure.core.util.Context context)
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.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The properties specified here will overwrite the corresponding properties in the existing cluster (ie. Those properties will be updated).ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.context
- The context to associate with this operation.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
update
ClusterInner update(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch)
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.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The properties specified here will overwrite the corresponding properties in the existing cluster (ie. Those properties will be updated).ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
update
ClusterInner update(String resourceGroupName, String clusterName, ClusterInner cluster)
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.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The properties specified here will overwrite the corresponding properties in the existing cluster (ie. Those properties will be updated).- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
update
ClusterInner update(String resourceGroupName, String clusterName, ClusterInner cluster, String ifMatch, com.azure.core.util.Context context)
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.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.cluster
- The properties specified here will overwrite the corresponding properties in the existing cluster (ie. Those properties will be updated).ifMatch
- The ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.context
- The context to associate with this operation.- Returns:
- a Stream Analytics Cluster object.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
getByResourceGroup
ClusterInner getByResourceGroup(String resourceGroupName, String clusterName)
Gets information about the specified cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.- Returns:
- information about the specified cluster.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
getByResourceGroupWithResponse
com.azure.core.http.rest.Response<ClusterInner> getByResourceGroupWithResponse(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Gets information about the specified cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.context
- The context to associate with this operation.- Returns:
- information about the specified cluster.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
beginDelete
com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<Void>,Void> beginDelete(String resourceGroupName, String clusterName)
Deletes the specified cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.- Returns:
- the completion.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
beginDelete
com.azure.core.util.polling.SyncPoller<com.azure.core.management.polling.PollResult<Void>,Void> beginDelete(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Deletes the specified cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.context
- The context to associate with this operation.- Returns:
- the completion.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
delete
void delete(String resourceGroupName, String clusterName)
Deletes the specified cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
delete
void delete(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Deletes the specified cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.context
- The context to associate with this operation.- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
list
com.azure.core.http.rest.PagedIterable<ClusterInner> list()
Lists all of the clusters in the given subscription.- Returns:
- a list of clusters populated by a 'list' operation.
- Throws:
com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
list
com.azure.core.http.rest.PagedIterable<ClusterInner> list(com.azure.core.util.Context context)
Lists all of the clusters in the given subscription.- Parameters:
context
- The context to associate with this operation.- Returns:
- a list of clusters populated by a 'list' operation.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
listByResourceGroup
com.azure.core.http.rest.PagedIterable<ClusterInner> listByResourceGroup(String resourceGroupName)
Lists all of the clusters in the given resource group.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.- Returns:
- a list of clusters populated by a 'list' operation.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
listByResourceGroup
com.azure.core.http.rest.PagedIterable<ClusterInner> listByResourceGroup(String resourceGroupName, com.azure.core.util.Context context)
Lists all of the clusters in the given resource group.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.context
- The context to associate with this operation.- Returns:
- a list of clusters populated by a 'list' operation.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
listStreamingJobs
com.azure.core.http.rest.PagedIterable<ClusterJobInner> listStreamingJobs(String resourceGroupName, String clusterName)
Lists all of the streaming jobs in the given cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.- Returns:
- a list of streaming jobs.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
listStreamingJobs
com.azure.core.http.rest.PagedIterable<ClusterJobInner> listStreamingJobs(String resourceGroupName, String clusterName, com.azure.core.util.Context context)
Lists all of the streaming jobs in the given cluster.- Parameters:
resourceGroupName
- The name of the resource group. The name is case insensitive.clusterName
- The name of the cluster.context
- The context to associate with this operation.- Returns:
- a list of streaming jobs.
- Throws:
IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.management.exception.ManagementException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.
-
-