Compartir a través de


SparkSessionClient Clase

Definición

El cliente del servicio SparkSession.

public class SparkSessionClient
type SparkSessionClient = class
Public Class SparkSessionClient
Herencia
SparkSessionClient

Constructores

SparkSessionClient()

Inicializa una nueva instancia de SparkSessionClient para simular.

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

Inicializa una nueva instancia de SparkSessionClient.

Métodos

CancelSparkSession(Int32, CancellationToken)

Cancela una sesión de Spark en ejecución.

CancelSparkSessionAsync(Int32, CancellationToken)

Cancela una sesión de Spark en ejecución.

CancelSparkStatement(Int32, Int32, CancellationToken)

Elimine una instrucción dentro de una sesión.

CancelSparkStatementAsync(Int32, Int32, CancellationToken)

Elimine una instrucción dentro de una sesión.

GetSparkSession(Int32, Nullable<Boolean>, CancellationToken)

Obtiene una sola sesión de Spark.

GetSparkSessionAsync(Int32, Nullable<Boolean>, CancellationToken)

Obtiene una sola sesión de Spark.

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

Enumere todas las sesiones de Spark que se ejecutan en un grupo de Spark determinado.

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

Enumere todas las sesiones de Spark que se ejecutan en un grupo de Spark determinado.

GetSparkStatement(Int32, Int32, CancellationToken)

Obtiene una sola instrucción dentro de una sesión de Spark.

GetSparkStatementAsync(Int32, Int32, CancellationToken)

Obtiene una sola instrucción dentro de una sesión de Spark.

GetSparkStatements(Int32, CancellationToken)

Obtiene una lista de instrucciones dentro de una sesión de Spark.

GetSparkStatementsAsync(Int32, CancellationToken)

Obtiene una lista de instrucciones dentro de una sesión de Spark.

ResetSparkSessionTimeout(Int32, CancellationToken)

Envía una llamada keep alive a la sesión actual para restablecer el tiempo de espera de la sesión.

ResetSparkSessionTimeoutAsync(Int32, CancellationToken)

Envía una llamada keep alive a la sesión actual para restablecer el tiempo de espera de la sesión.

StartCreateSparkSession(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

El cliente del servicio SparkSession.

StartCreateSparkSessionAsync(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

El cliente del servicio SparkSession.

StartCreateSparkStatement(Int32, SparkStatementOptions, CancellationToken)

El cliente del servicio SparkSession.

StartCreateSparkStatementAsync(Int32, SparkStatementOptions, CancellationToken)

El cliente del servicio SparkSession.

Se aplica a