SparkJobDefinitionAsyncClient Class

Package:

com.azure.analytics.synapse.artifacts

Maven Artifact:

com.azure:azure-analytics-synapse-artifacts:1.0.0-beta.15

• java.lang.Object
• • com.azure.analytics.synapse.artifacts.SparkJobDefinitionAsyncClient

public final class SparkJobDefinitionAsyncClient

Initializes a new instance of the asynchronous ArtifactsClient type.

Method Summary

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<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<Response<SparkBatchJob>>	debugSparkJobDefinitionWithResponse(SparkJobDefinitionResource sparkJobDefinitionAzureResource) Debug the spark job definition.
Mono<Void>	deleteSparkJobDefinition(String sparkJobDefinitionName) Deletes a Spark Job Definition.
Mono<Response<Void>>	deleteSparkJobDefinitionWithResponse(String sparkJobDefinitionName) Deletes a Spark Job Definition.
Mono<SparkBatchJob>	executeSparkJobDefinition(String sparkJobDefinitionName) Executes the spark job definition.
Mono<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.
Mono<Response<SparkJobDefinitionResource>>	getSparkJobDefinitionWithResponse(String sparkJobDefinitionName, String ifNoneMatch) Gets a Spark Job Definition.
PagedFlux<SparkJobDefinitionResource>	getSparkJobDefinitionsByWorkspace() Lists spark job definitions.
Mono<Void>	renameSparkJobDefinition(String sparkJobDefinitionName, ArtifactRenameRequest request) Renames a sparkJobDefinition.
Mono<Response<Void>>	renameSparkJobDefinitionWithResponse(String sparkJobDefinitionName, ArtifactRenameRequest request) Renames a sparkJobDefinition.

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Method Details

createOrUpdateSparkJobDefinition

public Mono createOrUpdateSparkJobDefinition(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition)

Creates or updates a Spark Job Definition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

sparkJobDefinition - Spark Job Definition resource definition.

Returns:

spark job definition resource type on successful completion of Mono.

createOrUpdateSparkJobDefinition

public Mono createOrUpdateSparkJobDefinition(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition, String ifMatch)

Creates or updates a Spark Job Definition.

Parameters:

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.

Returns:

spark job definition resource type on successful completion of Mono.

createOrUpdateSparkJobDefinitionWithResponse

public Mono<>> createOrUpdateSparkJobDefinitionWithResponse(String sparkJobDefinitionName, SparkJobDefinitionResource sparkJobDefinition, String ifMatch)

Creates or updates a Spark Job Definition.

Parameters:

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.

Returns:

spark job definition resource type along with Response<T> on successful completion of Mono.

debugSparkJobDefinition

public Mono debugSparkJobDefinition(SparkJobDefinitionResource sparkJobDefinitionAzureResource)

Debug the spark job definition.

Parameters:

sparkJobDefinitionAzureResource - Spark Job Definition resource definition.

Returns:

the response body on successful completion of Mono.

debugSparkJobDefinitionWithResponse

public Mono<>> debugSparkJobDefinitionWithResponse(SparkJobDefinitionResource sparkJobDefinitionAzureResource)

Debug the spark job definition.

Parameters:

sparkJobDefinitionAzureResource - Spark Job Definition resource definition.

Returns:

the response body along with Response<T> on successful completion of Mono.

deleteSparkJobDefinition

public Mono deleteSparkJobDefinition(String sparkJobDefinitionName)

Deletes a Spark Job Definition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

Returns:

A Mono that completes when a successful response is received.

deleteSparkJobDefinitionWithResponse

public Mono<>> deleteSparkJobDefinitionWithResponse(String sparkJobDefinitionName)

Deletes a Spark Job Definition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

Returns:

the Response<T> on successful completion of Mono.

executeSparkJobDefinition

public Mono executeSparkJobDefinition(String sparkJobDefinitionName)

Executes the spark job definition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

Returns:

the response body on successful completion of Mono.

executeSparkJobDefinitionWithResponse

public Mono<>> executeSparkJobDefinitionWithResponse(String sparkJobDefinitionName)

Executes the spark job definition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

Returns:

the response body along with Response<T> on successful completion of Mono.

getSparkJobDefinition

public Mono getSparkJobDefinition(String sparkJobDefinitionName)

Gets a Spark Job Definition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

Returns:

a Spark Job Definition on successful completion of Mono.

getSparkJobDefinition

public Mono getSparkJobDefinition(String sparkJobDefinitionName, String ifNoneMatch)

Gets a Spark Job Definition.

Parameters:

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.

Returns:

a Spark Job Definition on successful completion of Mono.

getSparkJobDefinitionWithResponse

public Mono<>> getSparkJobDefinitionWithResponse(String sparkJobDefinitionName, String ifNoneMatch)

Gets a Spark Job Definition.

Parameters:

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.

Returns:

a Spark Job Definition along with Response<T> on successful completion of Mono.

getSparkJobDefinitionsByWorkspace

public PagedFlux getSparkJobDefinitionsByWorkspace()

Lists spark job definitions.

Returns:

a list of spark job definitions resources as paginated response with PagedFlux<T>.

renameSparkJobDefinition

public Mono renameSparkJobDefinition(String sparkJobDefinitionName, ArtifactRenameRequest request)

Renames a sparkJobDefinition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

request - proposed new name.

Returns:

A Mono that completes when a successful response is received.

renameSparkJobDefinitionWithResponse

public Mono<>> renameSparkJobDefinitionWithResponse(String sparkJobDefinitionName, ArtifactRenameRequest request)

Renames a sparkJobDefinition.

Parameters:

sparkJobDefinitionName - The spark job definition name.

request - proposed new name.

Returns:

the Response<T> on successful completion of Mono.