public final class SparkJobDefinitionAsyncClient extends Object
Modifier and Type | Method and Description |
---|---|
Mono<SparkJobDefinitionResource> |
createOrUpdateSparkJobDefinition(String sparkJobDefinitionName,
SparkJobDefinitionResource sparkJobDefinition)
Creates or updates a Spark Job Definition.
|
Mono<SparkJobDefinitionResource> |
createOrUpdateSparkJobDefinition(String sparkJobDefinitionName,
SparkJobDefinitionResource sparkJobDefinition,
String ifMatch)
Creates or updates a Spark Job Definition.
|
Mono<com.azure.core.http.rest.Response<SparkJobDefinitionResource>> |
createOrUpdateSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
SparkJobDefinitionResource sparkJobDefinition,
String ifMatch)
Creates or updates a Spark Job Definition.
|
Mono<SparkBatchJob> |
debugSparkJobDefinition(SparkJobDefinitionResource sparkJobDefinitionAzureResource)
Debug the spark job definition.
|
Mono<com.azure.core.http.rest.Response<SparkBatchJob>> |
debugSparkJobDefinitionWithResponse(SparkJobDefinitionResource sparkJobDefinitionAzureResource)
Debug the spark job definition.
|
Mono<Void> |
deleteSparkJobDefinition(String sparkJobDefinitionName)
Deletes a Spark Job Definition.
|
Mono<com.azure.core.http.rest.Response<Void>> |
deleteSparkJobDefinitionWithResponse(String sparkJobDefinitionName)
Deletes a Spark Job Definition.
|
Mono<SparkBatchJob> |
executeSparkJobDefinition(String sparkJobDefinitionName)
Executes the spark job definition.
|
Mono<com.azure.core.http.rest.Response<SparkBatchJob>> |
executeSparkJobDefinitionWithResponse(String sparkJobDefinitionName)
Executes the spark job definition.
|
Mono<SparkJobDefinitionResource> |
getSparkJobDefinition(String sparkJobDefinitionName)
Gets a Spark Job Definition.
|
Mono<SparkJobDefinitionResource> |
getSparkJobDefinition(String sparkJobDefinitionName,
String ifNoneMatch)
Gets a Spark Job Definition.
|
com.azure.core.http.rest.PagedFlux<SparkJobDefinitionResource> |
getSparkJobDefinitionsByWorkspace()
Lists spark job definitions.
|
Mono<com.azure.core.http.rest.Response<SparkJobDefinitionResource>> |
getSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
String ifNoneMatch)
Gets a Spark Job Definition.
|
Mono<Void> |
renameSparkJobDefinition(String sparkJobDefinitionName,
ArtifactRenameRequest request)
Renames a sparkJobDefinition.
|
Mono<com.azure.core.http.rest.Response<Void>> |
renameSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
ArtifactRenameRequest request)
Renames a sparkJobDefinition.
|
public com.azure.core.http.rest.PagedFlux<SparkJobDefinitionResource> getSparkJobDefinitionsByWorkspace()
CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<com.azure.core.http.rest.Response<SparkJobDefinitionResource>> createOrUpdateSparkJobDefinitionWithResponse(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition, String ifMatch)
sparkJobDefinitionName
- The spark job definition name.sparkJobDefinition
- Spark Job Definition resource definition.ifMatch
- ETag of the Spark Job Definition entity. Should only be specified for update, for which it should
match existing entity or can be * for unconditional update.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkJobDefinitionResource> createOrUpdateSparkJobDefinition(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition, String ifMatch)
sparkJobDefinitionName
- The spark job definition name.sparkJobDefinition
- Spark Job Definition resource definition.ifMatch
- ETag of the Spark Job Definition entity. Should only be specified for update, for which it should
match existing entity or can be * for unconditional update.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkJobDefinitionResource> createOrUpdateSparkJobDefinition(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition)
sparkJobDefinitionName
- The spark job definition name.sparkJobDefinition
- Spark Job Definition resource definition.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<com.azure.core.http.rest.Response<SparkJobDefinitionResource>> getSparkJobDefinitionWithResponse(String sparkJobDefinitionName, String ifNoneMatch)
sparkJobDefinitionName
- The spark job definition name.ifNoneMatch
- ETag of the Spark Job Definition entity. Should only be specified for get. If the ETag matches
the existing entity tag, or if * was provided, then no content will be returned.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkJobDefinitionResource> getSparkJobDefinition(String sparkJobDefinitionName, String ifNoneMatch)
sparkJobDefinitionName
- The spark job definition name.ifNoneMatch
- ETag of the Spark Job Definition entity. Should only be specified for get. If the ETag matches
the existing entity tag, or if * was provided, then no content will be returned.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkJobDefinitionResource> getSparkJobDefinition(String sparkJobDefinitionName)
sparkJobDefinitionName
- The spark job definition name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<com.azure.core.http.rest.Response<Void>> deleteSparkJobDefinitionWithResponse(String sparkJobDefinitionName)
sparkJobDefinitionName
- The spark job definition name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<Void> deleteSparkJobDefinition(String sparkJobDefinitionName)
sparkJobDefinitionName
- The spark job definition name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<com.azure.core.http.rest.Response<SparkBatchJob>> executeSparkJobDefinitionWithResponse(String sparkJobDefinitionName)
sparkJobDefinitionName
- The spark job definition name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJob> executeSparkJobDefinition(String sparkJobDefinitionName)
sparkJobDefinitionName
- The spark job definition name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<com.azure.core.http.rest.Response<Void>> renameSparkJobDefinitionWithResponse(String sparkJobDefinitionName, ArtifactRenameRequest request)
sparkJobDefinitionName
- The spark job definition name.request
- proposed new name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<Void> renameSparkJobDefinition(String sparkJobDefinitionName, ArtifactRenameRequest request)
sparkJobDefinitionName
- The spark job definition name.request
- proposed new name.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<com.azure.core.http.rest.Response<SparkBatchJob>> debugSparkJobDefinitionWithResponse(SparkJobDefinitionResource sparkJobDefinitionAzureResource)
sparkJobDefinitionAzureResource
- Spark Job Definition resource definition.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJob> debugSparkJobDefinition(SparkJobDefinitionResource sparkJobDefinitionAzureResource)
sparkJobDefinitionAzureResource
- Spark Job Definition resource definition.IllegalArgumentException
- thrown if parameters fail the validation.CloudErrorAutoGeneratedException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.Visit the Azure for Java Developers site for more Java documentation, including quick starts, tutorials, and code samples.