Compartilhar via


SparkSessionClient Classe

Definição

O cliente do serviço SparkSession.

public class SparkSessionClient
type SparkSessionClient = class
Public Class SparkSessionClient
Herança
SparkSessionClient

Construtores

SparkSessionClient()

Inicializa uma nova instância do SparkSessionClient para zombar.

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

Inicializa uma nova instância do SparkSessionClient.

Métodos

CancelSparkSession(Int32, CancellationToken)

Cancela uma sessão do Spark em execução.

CancelSparkSessionAsync(Int32, CancellationToken)

Cancela uma sessão do Spark em execução.

CancelSparkStatement(Int32, Int32, CancellationToken)

Encerre uma instrução em uma sessão.

CancelSparkStatementAsync(Int32, Int32, CancellationToken)

Encerre uma instrução em uma sessão.

GetSparkSession(Int32, Nullable<Boolean>, CancellationToken)

Obtém uma única sessão do Spark.

GetSparkSessionAsync(Int32, Nullable<Boolean>, CancellationToken)

Obtém uma única sessão do Spark.

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

Liste todas as sessões do Spark em execução em um pool específico do Spark.

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

Liste todas as sessões do Spark em execução em um pool específico do Spark.

GetSparkStatement(Int32, Int32, CancellationToken)

Obtém uma única instrução em uma sessão do Spark.

GetSparkStatementAsync(Int32, Int32, CancellationToken)

Obtém uma única instrução em uma sessão do Spark.

GetSparkStatements(Int32, CancellationToken)

Obtém uma lista de instruções em uma sessão do Spark.

GetSparkStatementsAsync(Int32, CancellationToken)

Obtém uma lista de instruções em uma sessão do Spark.

ResetSparkSessionTimeout(Int32, CancellationToken)

Envia uma chamada keep alive para a sessão atual para redefinir o tempo limite da sessão.

ResetSparkSessionTimeoutAsync(Int32, CancellationToken)

Envia uma chamada keep alive para a sessão atual para redefinir o tempo limite da sessão.

StartCreateSparkSession(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

O cliente do serviço SparkSession.

StartCreateSparkSessionAsync(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

O cliente do serviço SparkSession.

StartCreateSparkStatement(Int32, SparkStatementOptions, CancellationToken)

O cliente do serviço SparkSession.

StartCreateSparkStatementAsync(Int32, SparkStatementOptions, CancellationToken)

O cliente do serviço SparkSession.

Aplica-se a