SparkSession class

Pacote:: @azure/synapse

Classe que representa um SparkSession.

Construtores

Crie um SparkSession.

Métodos

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Crie uma nova sessão de faísca.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Criar instrução dentro de uma sessão de faísca.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Cancela uma sessão de faísca em execução.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Mate uma instrução dentro de uma sessão.
deleteStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementCancellationResponse>)
deleteStatement(string, string, number, number, ServiceCallback<LivyStatementCancellationResponse>)
get(string, string, number, ServiceCallback<ExtendedLivySessionResponse>)
get(string, string, number, SparkSessionGetOptionalParams)	Obtém uma única sessão de faísca.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Obtém uma única instrução dentro de uma sessão de faísca.
getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)
list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)
list(string, string, SparkSessionListOptionalParams)	Liste todas as sessões de faísca que estão sendo executadas sob um pool de faíscas específico.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Obtém uma lista de instruções dentro de uma sessão de faísca.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Envia uma chamada de manutenção ativa para a sessão atual para redefinir o tempo limite da sessão.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Detalhes do Construtor

SparkSession(SynapseClientContext)

Crie um SparkSession.

new SparkSession(client: SynapseClientContext)

Parâmetros

client: SynapseClientContext

Referência ao cliente do serviço.

Detalhes de Método

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)

function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

livyRequest: ExtendedLivySessionRequest

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

callback: ServiceCallback<ExtendedLivySessionResponse>

O retorno de chamada

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Crie uma nova sessão de faísca.

function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, options?: SparkSessionCreateOptionalParams): Promise<SparkSessionCreateResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

livyRequest: ExtendedLivySessionRequest

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

options: SparkSessionCreateOptionalParams

Os parâmetros opcionais

Devoluções

Promise<SparkSessionCreateResponse>

Modelos de promessa.SparkSessionCreateResponse<>

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)

function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, options: SparkSessionCreateOptionalParams, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

livyRequest: ExtendedLivySessionRequest

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

options: SparkSessionCreateOptionalParams

Os parâmetros opcionais

callback: ServiceCallback<ExtendedLivySessionResponse>

O retorno de chamada

createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)

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

function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, options?: RequestOptionsBase): Promise<SparkSessionCreateStatementResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

livyRequest: LivyStatementRequestBody

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

options: RequestOptionsBase

Os parâmetros opcionais

Devoluções

Promise<SparkSessionCreateStatementResponse>

Modelos de promessa.SparkSessionCreateStatementResponse<>

createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)

function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementResponseBody>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

livyRequest: LivyStatementRequestBody

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

options: RequestOptionsBase

Os parâmetros opcionais

callback: ServiceCallback<LivyStatementResponseBody>

O retorno de chamada

createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)

function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, callback: ServiceCallback<LivyStatementResponseBody>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

livyRequest: LivyStatementRequestBody

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

callback: ServiceCallback<LivyStatementResponseBody>

O retorno de chamada

deleteMethod(string, string, number, RequestOptionsBase)

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

function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<RestResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

Devoluções

Promise<RestResponse>

Prometa<> msRest.RestResponse

deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)

function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

callback: ServiceCallback<void>

O retorno de chamada

deleteMethod(string, string, number, ServiceCallback<void>)

function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<void>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

callback: ServiceCallback<void>

O retorno de chamada

deleteStatement(string, string, number, number, RequestOptionsBase)

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

function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options?: RequestOptionsBase): Promise<SparkSessionDeleteStatementResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

options: RequestOptionsBase

Os parâmetros opcionais

Devoluções

Promise<SparkSessionDeleteStatementResponse>

Promise<Models.SparkSessionDeleteStatementResponse>

deleteStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementCancellationResponse>)

function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementCancellationResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

options: RequestOptionsBase

Os parâmetros opcionais

callback: ServiceCallback<LivyStatementCancellationResponse>

O retorno de chamada

deleteStatement(string, string, number, number, ServiceCallback<LivyStatementCancellationResponse>)

function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, callback: ServiceCallback<LivyStatementCancellationResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

callback: ServiceCallback<LivyStatementCancellationResponse>

O retorno de chamada

get(string, string, number, ServiceCallback<ExtendedLivySessionResponse>)

function get(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

callback: ServiceCallback<ExtendedLivySessionResponse>

O retorno de chamada

get(string, string, number, SparkSessionGetOptionalParams)

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

function get(workspaceName: string, sparkPoolName: string, sessionId: number, options?: SparkSessionGetOptionalParams): Promise<SparkSessionGetResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: SparkSessionGetOptionalParams

Os parâmetros opcionais

Devoluções

Promise<SparkSessionGetResponse>

Modelos de promessa.SparkSessionGetResponse<>

get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)

function get(workspaceName: string, sparkPoolName: string, sessionId: number, options: SparkSessionGetOptionalParams, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: SparkSessionGetOptionalParams

Os parâmetros opcionais

callback: ServiceCallback<ExtendedLivySessionResponse>

O retorno de chamada

getStatement(string, string, number, number, RequestOptionsBase)

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

function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options?: RequestOptionsBase): Promise<SparkSessionGetStatementResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

options: RequestOptionsBase

Os parâmetros opcionais

Devoluções

Promise<SparkSessionGetStatementResponse>

Modelos de promessa.SparkSessionGetStatementResponse<>

getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)

function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementResponseBody>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

options: RequestOptionsBase

Os parâmetros opcionais

callback: ServiceCallback<LivyStatementResponseBody>

O retorno de chamada

getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)

function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, callback: ServiceCallback<LivyStatementResponseBody>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

statementId: number

Identificador da instrução.

callback: ServiceCallback<LivyStatementResponseBody>

O retorno de chamada

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

function list(workspaceName: string, sparkPoolName: string, callback: ServiceCallback<ExtendedLivyListSessionResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

O retorno de chamada

list(string, string, SparkSessionListOptionalParams)

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

function list(workspaceName: string, sparkPoolName: string, options?: SparkSessionListOptionalParams): Promise<SparkSessionListResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

options: SparkSessionListOptionalParams

Os parâmetros opcionais

Devoluções

Promise<SparkSessionListResponse>

Modelos de promessa.SparkSessionListResponse<>

list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)

function list(workspaceName: string, sparkPoolName: string, options: SparkSessionListOptionalParams, callback: ServiceCallback<ExtendedLivyListSessionResponse>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

options: SparkSessionListOptionalParams

Os parâmetros opcionais

callback: ServiceCallback<ExtendedLivyListSessionResponse>

O retorno de chamada

listStatements(string, string, number, RequestOptionsBase)

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

function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<SparkSessionListStatementsResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

Devoluções

Promise<SparkSessionListStatementsResponse>

Modelos de Promessa.SparkSessionListStatementsResponse<>

listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)

function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementsResponseBody>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

callback: ServiceCallback<LivyStatementsResponseBody>

O retorno de chamada

listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)

function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<LivyStatementsResponseBody>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

callback: ServiceCallback<LivyStatementsResponseBody>

O retorno de chamada

resetTimeout(string, string, number, RequestOptionsBase)

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

function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<RestResponse>

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

Devoluções

Promise<RestResponse>

Prometa<> msRest.RestResponse

resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)

function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

callback: ServiceCallback<void>

O retorno de chamada

resetTimeout(string, string, number, ServiceCallback<void>)

function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<void>)

Parâmetros

workspaceName: string

O nome do espaço de trabalho no qual executar operações.

sparkPoolName: string

Nome da piscina de faíscas. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

callback: ServiceCallback<void>

O retorno de chamada