public final class SparkSessionAsyncClient extends Object
Modifier and Type | Method and Description |
---|---|
Mono<Void> |
cancelSparkSession(int sessionId)
Cancels a running spark session.
|
Mono<com.azure.core.http.rest.Response<Void>> |
cancelSparkSessionWithResponse(int sessionId)
Cancels a running spark session.
|
Mono<SparkStatementCancellationResult> |
cancelSparkStatement(int sessionId,
int statementId)
Kill a statement within a session.
|
Mono<com.azure.core.http.rest.Response<SparkStatementCancellationResult>> |
cancelSparkStatementWithResponse(int sessionId,
int statementId)
Kill a statement within a session.
|
Mono<SparkSession> |
createSparkSession(SparkSessionOptions sparkSessionOptions)
Create new spark session.
|
Mono<SparkSession> |
createSparkSession(SparkSessionOptions sparkSessionOptions,
Boolean detailed)
Create new spark session.
|
Mono<com.azure.core.http.rest.Response<SparkSession>> |
createSparkSessionWithResponse(SparkSessionOptions sparkSessionOptions,
Boolean detailed)
Create new spark session.
|
Mono<SparkStatement> |
createSparkStatement(int sessionId,
SparkStatementOptions sparkStatementOptions)
Create statement within a spark session.
|
Mono<com.azure.core.http.rest.Response<SparkStatement>> |
createSparkStatementWithResponse(int sessionId,
SparkStatementOptions sparkStatementOptions)
Create statement within a spark session.
|
Mono<SparkSession> |
getSparkSession(int sessionId)
Gets a single spark session.
|
Mono<SparkSession> |
getSparkSession(int sessionId,
Boolean detailed)
Gets a single spark session.
|
Mono<SparkSessionCollection> |
getSparkSessions()
List all spark sessions which are running under a particular spark pool.
|
Mono<SparkSessionCollection> |
getSparkSessions(Integer from,
Integer size,
Boolean detailed)
List all spark sessions which are running under a particular spark pool.
|
Mono<com.azure.core.http.rest.Response<SparkSessionCollection>> |
getSparkSessionsWithResponse(Integer from,
Integer size,
Boolean detailed)
List all spark sessions which are running under a particular spark pool.
|
Mono<com.azure.core.http.rest.Response<SparkSession>> |
getSparkSessionWithResponse(int sessionId,
Boolean detailed)
Gets a single spark session.
|
Mono<SparkStatement> |
getSparkStatement(int sessionId,
int statementId)
Gets a single statement within a spark session.
|
Mono<SparkStatementCollection> |
getSparkStatements(int sessionId)
Gets a list of statements within a spark session.
|
Mono<com.azure.core.http.rest.Response<SparkStatementCollection>> |
getSparkStatementsWithResponse(int sessionId)
Gets a list of statements within a spark session.
|
Mono<com.azure.core.http.rest.Response<SparkStatement>> |
getSparkStatementWithResponse(int sessionId,
int statementId)
Gets a single statement within a spark session.
|
Mono<Void> |
resetSparkSessionTimeout(int sessionId)
Sends a keep alive call to the current session to reset the session timeout.
|
Mono<com.azure.core.http.rest.Response<Void>> |
resetSparkSessionTimeoutWithResponse(int sessionId)
Sends a keep alive call to the current session to reset the session timeout.
|
public Mono<com.azure.core.http.rest.Response<SparkSessionCollection>> getSparkSessionsWithResponse(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<SparkSessionCollection> getSparkSessions(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<SparkSessionCollection> getSparkSessions()
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<SparkSession>> createSparkSessionWithResponse(SparkSessionOptions sparkSessionOptions, Boolean detailed)
sparkSessionOptions
- 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<SparkSession> createSparkSession(SparkSessionOptions sparkSessionOptions, Boolean detailed)
sparkSessionOptions
- 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<SparkSession> createSparkSession(SparkSessionOptions sparkSessionOptions)
sparkSessionOptions
- 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<SparkSession>> getSparkSessionWithResponse(int sessionId, Boolean detailed)
sessionId
- Identifier for the session.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<SparkSession> getSparkSession(int sessionId, Boolean detailed)
sessionId
- Identifier for the session.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<SparkSession> getSparkSession(int sessionId)
sessionId
- Identifier for the session.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>> cancelSparkSessionWithResponse(int sessionId)
sessionId
- Identifier for the session.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> cancelSparkSession(int sessionId)
sessionId
- Identifier for the session.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>> resetSparkSessionTimeoutWithResponse(int sessionId)
sessionId
- Identifier for the session.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> resetSparkSessionTimeout(int sessionId)
sessionId
- Identifier for the session.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<SparkStatementCollection>> getSparkStatementsWithResponse(int sessionId)
sessionId
- Identifier for the session.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<SparkStatementCollection> getSparkStatements(int sessionId)
sessionId
- Identifier for the session.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<SparkStatement>> createSparkStatementWithResponse(int sessionId, SparkStatementOptions sparkStatementOptions)
sessionId
- Identifier for the session.sparkStatementOptions
- 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<SparkStatement> createSparkStatement(int sessionId, SparkStatementOptions sparkStatementOptions)
sessionId
- Identifier for the session.sparkStatementOptions
- 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<SparkStatement>> getSparkStatementWithResponse(int sessionId, int statementId)
sessionId
- Identifier for the session.statementId
- Identifier for the statement.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<SparkStatement> getSparkStatement(int sessionId, int statementId)
sessionId
- Identifier for the session.statementId
- Identifier for the statement.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<SparkStatementCancellationResult>> cancelSparkStatementWithResponse(int sessionId, int statementId)
sessionId
- Identifier for the session.statementId
- Identifier for the statement.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<SparkStatementCancellationResult> cancelSparkStatement(int sessionId, int statementId)
sessionId
- Identifier for the session.statementId
- Identifier for the statement.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.