public final class SparkBatchClient extends Object
Modifier and Type | Method and Description |
---|---|
void |
cancelSparkBatchJob(int batchId)
Cancels a running spark batch job.
|
com.azure.core.http.rest.Response<Void> |
cancelSparkBatchJobWithResponse(int batchId,
com.azure.core.util.Context context)
Cancels a running spark batch job.
|
SparkBatchJob |
createSparkBatchJob(SparkBatchJobOptions sparkBatchJobOptions)
Create new spark batch job.
|
SparkBatchJob |
createSparkBatchJob(SparkBatchJobOptions sparkBatchJobOptions,
Boolean detailed)
Create new spark batch job.
|
com.azure.core.http.rest.Response<SparkBatchJob> |
createSparkBatchJobWithResponse(SparkBatchJobOptions sparkBatchJobOptions,
Boolean detailed,
com.azure.core.util.Context context)
Create new spark batch job.
|
SparkBatchJob |
getSparkBatchJob(int batchId)
Gets a single spark batch job.
|
SparkBatchJob |
getSparkBatchJob(int batchId,
Boolean detailed)
Gets a single spark batch job.
|
SparkBatchJobCollection |
getSparkBatchJobs()
List all spark batch jobs which are running under a particular spark pool.
|
SparkBatchJobCollection |
getSparkBatchJobs(Integer from,
Integer size,
Boolean detailed)
List all spark batch jobs which are running under a particular spark pool.
|
com.azure.core.http.rest.Response<SparkBatchJobCollection> |
getSparkBatchJobsWithResponse(Integer from,
Integer size,
Boolean detailed,
com.azure.core.util.Context context)
List all spark batch jobs which are running under a particular spark pool.
|
com.azure.core.http.rest.Response<SparkBatchJob> |
getSparkBatchJobWithResponse(int batchId,
Boolean detailed,
com.azure.core.util.Context context)
Gets a single spark batch job.
|
public 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 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 com.azure.core.http.rest.Response<SparkBatchJobCollection> getSparkBatchJobsWithResponse(Integer from, Integer size, Boolean detailed, com.azure.core.util.Context context)
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.context
- The context to associate with this operation.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 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 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 com.azure.core.http.rest.Response<SparkBatchJob> createSparkBatchJobWithResponse(SparkBatchJobOptions sparkBatchJobOptions, Boolean detailed, com.azure.core.util.Context context)
sparkBatchJobOptions
- Livy compatible batch job request payload.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.context
- The context to associate with this operation.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 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 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 com.azure.core.http.rest.Response<SparkBatchJob> getSparkBatchJobWithResponse(int batchId, Boolean detailed, com.azure.core.util.Context context)
batchId
- Identifier for the batch job.detailed
- Optional query param specifying whether detailed response is returned beyond plain livy.context
- The context to associate with this operation.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 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.public com.azure.core.http.rest.Response<Void> cancelSparkBatchJobWithResponse(int batchId, com.azure.core.util.Context context)
batchId
- Identifier for the batch job.context
- The context to associate with this operation.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.