Partager via


SparkSessionClient Classe

Définition

Client du service SparkSession.

public class SparkSessionClient
type SparkSessionClient = class
Public Class SparkSessionClient
Héritage
SparkSessionClient

Constructeurs

SparkSessionClient()

Initialise une nouvelle instance de SparkSessionClient pour les moqueries.

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

Initialise une nouvelle instance de SparkSessionClient.

Méthodes

CancelSparkSession(Int32, CancellationToken)

Annule une session Spark en cours d’exécution.

CancelSparkSessionAsync(Int32, CancellationToken)

Annule une session Spark en cours d’exécution.

CancelSparkStatement(Int32, Int32, CancellationToken)

Tuer une instruction au sein d’une session.

CancelSparkStatementAsync(Int32, Int32, CancellationToken)

Tuer une instruction au sein d’une session.

GetSparkSession(Int32, Nullable<Boolean>, CancellationToken)

Obtient une seule session Spark.

GetSparkSessionAsync(Int32, Nullable<Boolean>, CancellationToken)

Obtient une seule session Spark.

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

Répertoriez toutes les sessions Spark qui s’exécutent sous un pool Spark particulier.

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

Répertoriez toutes les sessions Spark qui s’exécutent sous un pool Spark particulier.

GetSparkStatement(Int32, Int32, CancellationToken)

Obtient une instruction unique au sein d’une session Spark.

GetSparkStatementAsync(Int32, Int32, CancellationToken)

Obtient une instruction unique au sein d’une session Spark.

GetSparkStatements(Int32, CancellationToken)

Obtient une liste d’instructions au sein d’une session Spark.

GetSparkStatementsAsync(Int32, CancellationToken)

Obtient une liste d’instructions au sein d’une session Spark.

ResetSparkSessionTimeout(Int32, CancellationToken)

Envoie un appel de maintien actif à la session active pour réinitialiser le délai d’expiration de la session.

ResetSparkSessionTimeoutAsync(Int32, CancellationToken)

Envoie un appel de maintien actif à la session active pour réinitialiser le délai d’expiration de la session.

StartCreateSparkSession(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

Client du service SparkSession.

StartCreateSparkSessionAsync(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

Client du service SparkSession.

StartCreateSparkStatement(Int32, SparkStatementOptions, CancellationToken)

Client du service SparkSession.

StartCreateSparkStatementAsync(Int32, SparkStatementOptions, CancellationToken)

Client du service SparkSession.

S’applique à