SparkSessionOperations interface

Paquete:

@azure/synapse-spark

Interfaz que representa sparkSessionOperations.

Métodos

cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)	Cancela una sesión de Spark en ejecución.
cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)	Elimine una instrucción dentro de una sesión.
createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)	Cree una nueva sesión de Spark.
createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)	Cree una instrucción dentro de una sesión de Spark.
getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)	Obtiene una sola sesión de Spark.
getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)	Enumere todas las sesiones de Spark que se ejecutan en un grupo de Spark determinado.
getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)	Obtiene una única instrucción dentro de una sesión de Spark.
getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)	Obtiene una lista de instrucciones dentro de una sesión de Spark.
resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)	Envía una llamada keep alive a la sesión actual para restablecer el tiempo de espera de la sesión.

Detalles del método

cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)

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

function cancelSparkSession(sessionId: number, options?: SparkSessionCancelSparkSessionOptionalParams): Promise<void>

Parámetros

sessionId

number

Identificador de la sesión.

options

SparkSessionCancelSparkSessionOptionalParams

Parámetros de opciones.

Devoluciones

Promise<void>

cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)

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

function cancelSparkStatement(sessionId: number, statementId: number, options?: SparkSessionCancelSparkStatementOptionalParams): Promise<SparkStatementCancellationResult>

Parámetros

sessionId

number

Identificador de la sesión.

statementId

number

Identificador de la instrucción .

options

SparkSessionCancelSparkStatementOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkStatementCancellationResult>

createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)

Cree una nueva sesión de Spark.

function createSparkSession(sparkSessionOptions: SparkSessionOptions, options?: SparkSessionCreateSparkSessionOptionalParams): Promise<SparkSession>

Parámetros

sparkSessionOptions

SparkSessionOptions

Carga de la solicitud de trabajo por lotes compatible con Livy.

options

SparkSessionCreateSparkSessionOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkSession>

createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)

Cree una instrucción dentro de una sesión de Spark.

function createSparkStatement(sessionId: number, sparkStatementOptions: SparkStatementOptions, options?: SparkSessionCreateSparkStatementOptionalParams): Promise<SparkStatement>

Parámetros

sessionId

number

Identificador de la sesión.

sparkStatementOptions

SparkStatementOptions

Carga de la solicitud de trabajo por lotes compatible con Livy.

options

SparkSessionCreateSparkStatementOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkStatement>

getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)

Obtiene una sola sesión de Spark.

function getSparkSession(sessionId: number, options?: SparkSessionGetSparkSessionOptionalParams): Promise<SparkSession>

Parámetros

sessionId

number

Identificador de la sesión.

options

SparkSessionGetSparkSessionOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkSession>

getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)

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

function getSparkSessions(options?: SparkSessionGetSparkSessionsOptionalParams): Promise<SparkSessionCollection>

Parámetros

options

SparkSessionGetSparkSessionsOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkSessionCollection>

getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)

Obtiene una única instrucción dentro de una sesión de Spark.

function getSparkStatement(sessionId: number, statementId: number, options?: SparkSessionGetSparkStatementOptionalParams): Promise<SparkStatement>

Parámetros

sessionId

number

Identificador de la sesión.

statementId

number

Identificador de la instrucción .

options

SparkSessionGetSparkStatementOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkStatement>

getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)

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

function getSparkStatements(sessionId: number, options?: SparkSessionGetSparkStatementsOptionalParams): Promise<SparkStatementCollection>

Parámetros

sessionId

number

Identificador de la sesión.

options

SparkSessionGetSparkStatementsOptionalParams

Parámetros de opciones.

Devoluciones

Promise<SparkStatementCollection>

resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)

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

function resetSparkSessionTimeout(sessionId: number, options?: SparkSessionResetSparkSessionTimeoutOptionalParams): Promise<void>

Parámetros

sessionId

number

Identificador de la sesión.

options

SparkSessionResetSparkSessionTimeoutOptionalParams

Parámetros de opciones.

Devoluciones

Promise<void>