SparkSessionClient Class

Definition

The SparkSession service client.

public class SparkSessionClient
type SparkSessionClient = class
Public Class SparkSessionClient
Inheritance
SparkSessionClient

Constructors

SparkSessionClient()

Initializes a new instance of SparkSessionClient for mocking.

SparkSessionClient(Uri, String, TokenCredential, String, SparkClientOptions)

Initializes a new instance of SparkSessionClient.

Methods

CancelSparkSession(Int32, CancellationToken)

Cancels a running spark session.

CancelSparkSessionAsync(Int32, CancellationToken)

Cancels a running spark session.

CancelSparkStatement(Int32, Int32, CancellationToken)

Kill a statement within a session.

CancelSparkStatementAsync(Int32, Int32, CancellationToken)

Kill a statement within a session.

GetSparkSession(Int32, Nullable<Boolean>, CancellationToken)

Gets a single spark session.

GetSparkSessionAsync(Int32, Nullable<Boolean>, CancellationToken)

Gets a single spark session.

GetSparkSessions(Nullable<Int32>, Nullable<Int32>, Nullable<Boolean>, CancellationToken)

List all spark sessions which are running under a particular spark pool.

GetSparkSessionsAsync(Nullable<Int32>, Nullable<Int32>, Nullable<Boolean>, CancellationToken)

List all spark sessions which are running under a particular spark pool.

GetSparkStatement(Int32, Int32, CancellationToken)

Gets a single statement within a spark session.

GetSparkStatementAsync(Int32, Int32, CancellationToken)

Gets a single statement within a spark session.

GetSparkStatements(Int32, CancellationToken)

Gets a list of statements within a spark session.

GetSparkStatementsAsync(Int32, CancellationToken)

Gets a list of statements within a spark session.

ResetSparkSessionTimeout(Int32, CancellationToken)

Sends a keep alive call to the current session to reset the session timeout.

ResetSparkSessionTimeoutAsync(Int32, CancellationToken)

Sends a keep alive call to the current session to reset the session timeout.

StartCreateSparkSession(SparkSessionOptions, Nullable<Boolean>, CancellationToken)
StartCreateSparkSessionAsync(SparkSessionOptions, Nullable<Boolean>, CancellationToken)
StartCreateSparkStatement(Int32, SparkStatementOptions, CancellationToken)
StartCreateSparkStatementAsync(Int32, SparkStatementOptions, CancellationToken)

Applies to