public final class SparkBatchAsyncClient extends Object
Modifier and Type | Method and Description |
---|---|
Mono<Void> |
cancelSparkBatchJob(int batchId)
Cancels a running spark batch job.
|
Mono<com.azure.core.http.rest.Response<Void>> |
cancelSparkBatchJobWithResponse(int batchId)
Cancels a running spark batch job.
|
Mono<SparkBatchJob> |
createSparkBatchJob(SparkBatchJobOptions sparkBatchJobOptions)
Create new spark batch job.
|
Mono<SparkBatchJob> |
createSparkBatchJob(SparkBatchJobOptions sparkBatchJobOptions,
Boolean detailed)
Create new spark batch job.
|
Mono<com.azure.core.http.rest.Response<SparkBatchJob>> |
createSparkBatchJobWithResponse(SparkBatchJobOptions sparkBatchJobOptions,
Boolean detailed)
Create new spark batch job.
|
Mono<SparkBatchJob> |
getSparkBatchJob(int batchId)
Gets a single spark batch job.
|
Mono<SparkBatchJob> |
getSparkBatchJob(int batchId,
Boolean detailed)
Gets a single spark batch job.
|
Mono<SparkBatchJobCollection> |
getSparkBatchJobs()
List all spark batch jobs which are running under a particular spark pool.
|
Mono<SparkBatchJobCollection> |
getSparkBatchJobs(Integer from,
Integer size,
Boolean detailed)
List all spark batch jobs which are running under a particular spark pool.
|
Mono<com.azure.core.http.rest.Response<SparkBatchJobCollection>> |
getSparkBatchJobsWithResponse(Integer from,
Integer size,
Boolean detailed)
List all spark batch jobs which are running under a particular spark pool.
|
Mono<com.azure.core.http.rest.Response<SparkBatchJob>> |
getSparkBatchJobWithResponse(int batchId,
Boolean detailed)
Gets a single spark batch job.
|
public Mono<com.azure.core.http.rest.Response<SparkBatchJobCollection>> getSparkBatchJobsWithResponse(Integer from, Integer size, Boolean detailed)
from
- Optional param specifying which index the list should begin from.size
- Optional param specifying the size of the returned list. By default it is 20 and that is the maximum.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJobCollection> getSparkBatchJobs(Integer from, Integer size, Boolean detailed)
from
- Optional param specifying which index the list should begin from.size
- Optional param specifying the size of the returned list. By default it is 20 and that is the maximum.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJobCollection> getSparkBatchJobs()
com.azure.core.exception.HttpResponseException
- 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>> createSparkBatchJobWithResponse(SparkBatchJobOptions sparkBatchJobOptions, Boolean detailed)
sparkBatchJobOptions
- Livy compatible batch job request payload.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJob> createSparkBatchJob(SparkBatchJobOptions sparkBatchJobOptions, Boolean detailed)
sparkBatchJobOptions
- Livy compatible batch job request payload.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJob> createSparkBatchJob(SparkBatchJobOptions sparkBatchJobOptions)
sparkBatchJobOptions
- Livy compatible batch job request payload.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- 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>> getSparkBatchJobWithResponse(int batchId, Boolean detailed)
batchId
- Identifier for the batch job.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJob> getSparkBatchJob(int batchId, Boolean detailed)
batchId
- Identifier for the batch job.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<SparkBatchJob> getSparkBatchJob(int batchId)
batchId
- Identifier for the batch job.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- 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>> cancelSparkBatchJobWithResponse(int batchId)
batchId
- Identifier for the batch job.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.public Mono<Void> cancelSparkBatchJob(int batchId)
batchId
- Identifier for the batch job.IllegalArgumentException
- thrown if parameters fail the validation.com.azure.core.exception.HttpResponseException
- thrown if the request is rejected by server.RuntimeException
- all other wrapped checked exceptions if the request fails to be sent.Copyright © 2021 Microsoft Corporation. All rights reserved.