SparkSession class

Paquete:: @azure/synapse

Clase que representa una sparkSession.

Constructores

Cree una sparkSession.

Métodos

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Cree una nueva sesión de Spark.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Cree una instrucción dentro de una sesión de Spark.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Cancela una sesión de Spark en ejecución.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Elimine una instrucción dentro de una sesión.
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)	Obtiene una sola sesión de Spark.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Obtiene una única instrucción dentro de una sesión de 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)	Enumere todas las sesiones de Spark que se ejecutan en un grupo de Spark determinado.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Obtiene una lista de instrucciones dentro de una sesión de Spark.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Envía una llamada keep alive a la sesión actual para restablecer el tiempo de espera de la sesión.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Detalles del constructor

SparkSession(SynapseClientContext)

Cree una sparkSession.

new SparkSession(client: SynapseClientContext)

Parámetros

client: SynapseClientContext

Referencia al cliente de servicio.

Detalles del método

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

livyRequest: ExtendedLivySessionRequest

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

callback: ServiceCallback<ExtendedLivySessionResponse>

Devolución de llamada

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Cree una nueva sesión de Spark.

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

livyRequest: ExtendedLivySessionRequest

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

options: SparkSessionCreateOptionalParams

Los parámetros opcionales

Devoluciones

Promise<SparkSessionCreateResponse>

Modelos de promesa.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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

livyRequest: ExtendedLivySessionRequest

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

options: SparkSessionCreateOptionalParams

Los parámetros opcionales

callback: ServiceCallback<ExtendedLivySessionResponse>

Devolución de llamada

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

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

livyRequest: LivyStatementRequestBody

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

options: RequestOptionsBase

Los parámetros opcionales

Devoluciones

Promise<SparkSessionCreateStatementResponse>

Modelos de promesas.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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

livyRequest: LivyStatementRequestBody

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

options: RequestOptionsBase

Los parámetros opcionales

callback: ServiceCallback<LivyStatementResponseBody>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

livyRequest: LivyStatementRequestBody

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

callback: ServiceCallback<LivyStatementResponseBody>

Devolución de llamada

deleteMethod(string, string, number, RequestOptionsBase)

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: RequestOptionsBase

Los parámetros opcionales

Devoluciones

Promise<RestResponse>

Promesa<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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: RequestOptionsBase

Los parámetros opcionales

callback: ServiceCallback<void>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

callback: ServiceCallback<void>

Devolución de llamada

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

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

statementId: number

Identificador de la instrucción .

options: RequestOptionsBase

Los parámetros opcionales

Devoluciones

Promise<SparkSessionDeleteStatementResponse>

Modelos de promesas.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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

statementId: number

Identificador de la instrucción .

options: RequestOptionsBase

Los parámetros opcionales

callback: ServiceCallback<LivyStatementCancellationResponse>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

statementId: number

Identificador de la instrucción .

callback: ServiceCallback<LivyStatementCancellationResponse>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

callback: ServiceCallback<ExtendedLivySessionResponse>

Devolución de llamada

get(string, string, number, SparkSessionGetOptionalParams)

Obtiene una sola sesión de Spark.

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: SparkSessionGetOptionalParams

Los parámetros opcionales

Devoluciones

Promise<SparkSessionGetResponse>

Modelos de promesas.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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: SparkSessionGetOptionalParams

Los parámetros opcionales

callback: ServiceCallback<ExtendedLivySessionResponse>

Devolución de llamada

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

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

statementId: number

Identificador de la instrucción .

options: RequestOptionsBase

Los parámetros opcionales

Devoluciones

Promise<SparkSessionGetStatementResponse>

Modelos de promesa.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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

statementId: number

Identificador de la instrucción .

options: RequestOptionsBase

Los parámetros opcionales

callback: ServiceCallback<LivyStatementResponseBody>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

statementId: number

Identificador de la instrucción .

callback: ServiceCallback<LivyStatementResponseBody>

Devolución de llamada

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Devolución de llamada

list(string, string, SparkSessionListOptionalParams)

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

options: SparkSessionListOptionalParams

Los parámetros opcionales

Devoluciones

Promise<SparkSessionListResponse>

Modelos de promesa.SparkSessionListResponse<>

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

options: SparkSessionListOptionalParams

Los parámetros opcionales

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Devolución de llamada

listStatements(string, string, number, RequestOptionsBase)

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: RequestOptionsBase

Los parámetros opcionales

Devoluciones

Promise<SparkSessionListStatementsResponse>

Modelos de promesas.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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: RequestOptionsBase

Los parámetros opcionales

callback: ServiceCallback<LivyStatementsResponseBody>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

callback: ServiceCallback<LivyStatementsResponseBody>

Devolución de llamada

resetTimeout(string, string, number, RequestOptionsBase)

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: RequestOptionsBase

Los parámetros opcionales

Devoluciones

Promise<RestResponse>

Promesa<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

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

options: RequestOptionsBase

Los parámetros opcionales

callback: ServiceCallback<void>

Devolución de llamada

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

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

Parámetros

workspaceName: string

Nombre del área de trabajo en la que se van a ejecutar las operaciones.

sparkPoolName: string

Nombre del grupo de Spark. "ondemand" tiene como destino el grupo de ondemand.

sessionId: number

Identificador de la sesión.

callback: ServiceCallback<void>

Devolución de llamada