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 do Spark.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Crie uma instrução em uma sessão do Spark.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Cancela uma sessão do Spark em execução.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Encerre uma instrução em 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 do Spark.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Obtém uma única instrução em uma sessão do Spark.
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 do Spark que estão em execução em um pool específico do Spark.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Obtém uma lista de instruções em uma sessão do Spark.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Envia uma chamada keep alive 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 de serviço.

Detalhes do 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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

livyRequest: ExtendedLivySessionRequest

Conteúdo 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 do Spark.

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

livyRequest: ExtendedLivySessionRequest

Conteúdo de solicitação de trabalho em lote compatível com Livy.

options: SparkSessionCreateOptionalParams

Os parâmetros opcionais

Retornos

Promise<SparkSessionCreateResponse>

< Promise>Models.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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

livyRequest: ExtendedLivySessionRequest

Conteúdo 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)

Crie uma instrução em uma sessão do Spark.

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

livyRequest: LivyStatementRequestBody

Conteúdo de solicitação de trabalho em lote compatível com Livy.

options: RequestOptionsBase

Os parâmetros opcionais

Retornos

Promise<SparkSessionCreateStatementResponse>

Promessa<Models.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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

livyRequest: LivyStatementRequestBody

Conteúdo 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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

livyRequest: LivyStatementRequestBody

Conteúdo 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 do Spark em execução.

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

Retornos

Promise<RestResponse>

Promessa<> 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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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)

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

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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

Retornos

Promise<SparkSessionDeleteStatementResponse>

Promessa<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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 do Spark.

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: SparkSessionGetOptionalParams

Os parâmetros opcionais

Retornos

Promise<SparkSessionGetResponse>

< Promise>Models.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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 em uma sessão do Spark.

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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

Retornos

Promise<SparkSessionGetStatementResponse>

Promise<Models.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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

O retorno de chamada

list(string, string, SparkSessionListOptionalParams)

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

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

options: SparkSessionListOptionalParams

Os parâmetros opcionais

Retornos

Promise<SparkSessionListResponse>

< Promise>Models.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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 em uma sessão do Spark.

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

Parâmetros

workspaceName: string

O nome do workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

Retornos

Promise<SparkSessionListStatementsResponse>

Promise<Models.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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 keep alive 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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

options: RequestOptionsBase

Os parâmetros opcionais

Retornos

Promise<RestResponse>

Promessa<> 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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "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 workspace no qual executar as operações.

sparkPoolName: string

Nome do pool do Spark. "ondemand" tem como alvo o pool ondemand.

sessionId: number

Identificador da sessão.

callback: ServiceCallback<void>

O retorno de chamada