SparkSessionOperations interface

Pacote:: @azure/synapse-spark

Interface que representa um SparkSessionOperations.

Métodos

cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)	Cancela uma sessão de faísca em execução.
cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)	Mate uma instrução dentro de uma sessão.
createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)	Crie uma nova sessão de faísca.
createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)	Criar instrução dentro de uma sessão de faísca.
getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)	Obtém uma única sessão de faísca.
getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)	Liste todas as sessões de faísca que estão sendo executadas sob um pool de faíscas específico.
getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)	Obtém uma única instrução dentro de uma sessão de faísca.
getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)	Obtém uma lista de instruções dentro de uma sessão de faísca.
resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)	Envia uma chamada de manutenção ativa para a sessão atual para redefinir o tempo limite da sessão.

Detalhes de Método

cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)

Cancela uma sessão de faísca em execução.

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

Parâmetros

sessionId: number

Identificador da sessão.

options: SparkSessionCancelSparkSessionOptionalParams

Os parâmetros de opções.

Devoluções

Promise<void>

cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)

Mate uma instrução dentro de uma sessão.

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

Parâmetros

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

options: SparkSessionCancelSparkStatementOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkStatementCancellationResult>

createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)

Crie uma nova sessão de faísca.

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

Parâmetros

sparkSessionOptions: SparkSessionOptions

Carga útil de solicitação de trabalho em lote compatível com Livy.

options: SparkSessionCreateSparkSessionOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkSession>

createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)

Criar instrução dentro de uma sessão de faísca.

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

Parâmetros

sessionId: number

Identificador da sessão.

sparkStatementOptions: SparkStatementOptions

Carga útil de solicitação de trabalho em lote compatível com Livy.

options: SparkSessionCreateSparkStatementOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkStatement>

getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)

Obtém uma única sessão de faísca.

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

Parâmetros

sessionId: number

Identificador da sessão.

options: SparkSessionGetSparkSessionOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkSession>

getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)

Liste todas as sessões de faísca que estão sendo executadas sob um pool de faíscas específico.

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

Parâmetros

options: SparkSessionGetSparkSessionsOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkSessionCollection>

getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)

Obtém uma única instrução dentro de uma sessão de faísca.

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

Parâmetros

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

options: SparkSessionGetSparkStatementOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkStatement>

getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)

Obtém uma lista de instruções dentro de uma sessão de faísca.

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

Parâmetros

sessionId: number

Identificador da sessão.

options: SparkSessionGetSparkStatementsOptionalParams

Os parâmetros de opções.

Devoluções

Promise<SparkStatementCollection>

resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)

Envia uma chamada de manutenção ativa para a sessão atual para redefinir o tempo limite da sessão.

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

Parâmetros

sessionId: number

Identificador da sessão.

options: SparkSessionResetSparkSessionTimeoutOptionalParams

Os parâmetros de opções.

Devoluções

Promise<void>

Comentários

Esta página foi útil?