public final class SparkJobDefinitionClient extends Object
Modifier and Type | Method and Description |
---|---|
SparkJobDefinitionResource |
createOrUpdateSparkJobDefinition(String sparkJobDefinitionName,
SparkJobDefinitionResource sparkJobDefinition)
Creates or updates a Spark Job Definition.
|
SparkJobDefinitionResource |
createOrUpdateSparkJobDefinition(String sparkJobDefinitionName,
SparkJobDefinitionResource sparkJobDefinition,
String ifMatch)
Creates or updates a Spark Job Definition.
|
com.azure.core.http.rest.Response<SparkJobDefinitionResource> |
createOrUpdateSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
SparkJobDefinitionResource sparkJobDefinition,
String ifMatch,
com.azure.core.util.Context context)
Creates or updates a Spark Job Definition.
|
SparkBatchJob |
debugSparkJobDefinition(SparkJobDefinitionResource sparkJobDefinitionAzureResource)
Debug the spark job definition.
|
com.azure.core.http.rest.Response<SparkBatchJob> |
debugSparkJobDefinitionWithResponse(SparkJobDefinitionResource sparkJobDefinitionAzureResource,
com.azure.core.util.Context context)
Debug the spark job definition.
|
void |
deleteSparkJobDefinition(String sparkJobDefinitionName)
Deletes a Spark Job Definition.
|
com.azure.core.http.rest.Response<Void> |
deleteSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
com.azure.core.util.Context context)
Deletes a Spark Job Definition.
|
SparkBatchJob |
executeSparkJobDefinition(String sparkJobDefinitionName)
Executes the spark job definition.
|
com.azure.core.http.rest.Response<SparkBatchJob> |
executeSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
com.azure.core.util.Context context)
Executes the spark job definition.
|
SparkJobDefinitionResource |
getSparkJobDefinition(String sparkJobDefinitionName)
Gets a Spark Job Definition.
|
SparkJobDefinitionResource |
getSparkJobDefinition(String sparkJobDefinitionName,
String ifNoneMatch)
Gets a Spark Job Definition.
|
com.azure.core.http.rest.PagedIterable<SparkJobDefinitionResource> |
getSparkJobDefinitionsByWorkspace()
Lists spark job definitions.
|
com.azure.core.http.rest.PagedIterable<SparkJobDefinitionResource> |
getSparkJobDefinitionsByWorkspace(com.azure.core.util.Context context)
Lists spark job definitions.
|
com.azure.core.http.rest.Response<SparkJobDefinitionResource> |
getSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
String ifNoneMatch,
com.azure.core.util.Context context)
Gets a Spark Job Definition.
|
void |
renameSparkJobDefinition(String sparkJobDefinitionName,
ArtifactRenameRequest request)
Renames a sparkJobDefinition.
|
com.azure.core.http.rest.Response<Void> |
renameSparkJobDefinitionWithResponse(String sparkJobDefinitionName,
ArtifactRenameRequest request,
com.azure.core.util.Context context)
Renames a sparkJobDefinition.
|
public com.azure.core.http.rest.PagedIterable<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 com.azure.core.http.rest.PagedIterable<SparkJobDefinitionResource> getSparkJobDefinitionsByWorkspace(com.azure.core.util.Context context)
context
- The context to associate with this operation.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 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 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 com.azure.core.http.rest.Response<SparkJobDefinitionResource> createOrUpdateSparkJobDefinitionWithResponse(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition, String ifMatch, com.azure.core.util.Context context)
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.context
- The context to associate with this operation.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 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 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 com.azure.core.http.rest.Response<SparkJobDefinitionResource> getSparkJobDefinitionWithResponse(String sparkJobDefinitionName, String ifNoneMatch, com.azure.core.util.Context context)
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.context
- The context to associate with this operation.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 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 com.azure.core.http.rest.Response<Void> deleteSparkJobDefinitionWithResponse(String sparkJobDefinitionName, com.azure.core.util.Context context)
sparkJobDefinitionName
- The spark job definition name.context
- The context to associate with this operation.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 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 com.azure.core.http.rest.Response<SparkBatchJob> executeSparkJobDefinitionWithResponse(String sparkJobDefinitionName, com.azure.core.util.Context context)
sparkJobDefinitionName
- The spark job definition name.context
- The context to associate with this operation.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 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 com.azure.core.http.rest.Response<Void> renameSparkJobDefinitionWithResponse(String sparkJobDefinitionName, ArtifactRenameRequest request, com.azure.core.util.Context context)
sparkJobDefinitionName
- The spark job definition name.request
- proposed new name.context
- The context to associate with this operation.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 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.public com.azure.core.http.rest.Response<SparkBatchJob> debugSparkJobDefinitionWithResponse(SparkJobDefinitionResource sparkJobDefinitionAzureResource, com.azure.core.util.Context context)
sparkJobDefinitionAzureResource
- Spark Job Definition resource definition.context
- The context to associate with this operation.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.