SparkSession class

Pacchetto:

@azure/synapse

Classe che rappresenta una sessione SparkSession.

Costruttori

SparkSession(SynapseClientContext)

Creare una sessione SparkSession.

Metodi

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Creare una nuova sessione Spark.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Creare un'istruzione all'interno di una sessione Spark.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Annulla una sessione Spark in esecuzione.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Terminare un'istruzione all'interno di una sessione.
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)	Ottiene una singola sessione spark.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Ottiene una singola istruzione all'interno di una sessione 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)	Elencare tutte le sessioni Spark in esecuzione in un determinato pool di spark.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Ottiene un elenco di istruzioni all'interno di una sessione Spark.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Invia una chiamata keep-alive alla sessione corrente per reimpostare il timeout della sessione.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Dettagli costruttore

SparkSession(SynapseClientContext)

Creare una sessione SparkSession.

new SparkSession(client: SynapseClientContext)

Parametri

client

SynapseClientContext

Riferimento al client del servizio.

Dettagli metodo

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

livyRequest

ExtendedLivySessionRequest

Payload della richiesta di processo batch compatibile con Livy.

callback

ServiceCallback<ExtendedLivySessionResponse>

Callback

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Creare una nuova sessione Spark.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

livyRequest

ExtendedLivySessionRequest

Payload della richiesta di processo batch compatibile con Livy.

options

SparkSessionCreateOptionalParams

Parametri facoltativi

Restituisce

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

livyRequest

ExtendedLivySessionRequest

Payload della richiesta di processo batch compatibile con Livy.

options

SparkSessionCreateOptionalParams

Parametri facoltativi

callback

ServiceCallback<ExtendedLivySessionResponse>

Callback

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

Creare un'istruzione all'interno di una sessione Spark.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

livyRequest

LivyStatementRequestBody

Payload della richiesta di processo batch compatibile con Livy.

options

RequestOptionsBase

Parametri facoltativi

Restituisce

Promise<SparkSessionCreateStatementResponse>

Promise<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>)

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

livyRequest

LivyStatementRequestBody

Payload della richiesta di processo batch compatibile con Livy.

options

RequestOptionsBase

Parametri facoltativi

callback

ServiceCallback<LivyStatementResponseBody>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

livyRequest

LivyStatementRequestBody

Payload della richiesta di processo batch compatibile con Livy.

callback

ServiceCallback<LivyStatementResponseBody>

Callback

deleteMethod(string, string, number, RequestOptionsBase)

Annulla una sessione Spark in esecuzione.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

RequestOptionsBase

Parametri facoltativi

Restituisce

Promise<RestResponse>

Prometti<msRest.RestResponse>

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

RequestOptionsBase

Parametri facoltativi

callback

ServiceCallback<void>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

callback

ServiceCallback<void>

Callback

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

Terminare un'istruzione all'interno di una sessione.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

statementId

number

Identificatore per l'istruzione.

options

RequestOptionsBase

Parametri facoltativi

Restituisce

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

statementId

number

Identificatore per l'istruzione.

options

RequestOptionsBase

Parametri facoltativi

callback

ServiceCallback<LivyStatementCancellationResponse>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

statementId

number

Identificatore per l'istruzione.

callback

ServiceCallback<LivyStatementCancellationResponse>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

callback

ServiceCallback<ExtendedLivySessionResponse>

Callback

get(string, string, number, SparkSessionGetOptionalParams)

Ottiene una singola sessione spark.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

SparkSessionGetOptionalParams

Parametri facoltativi

Restituisce

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

SparkSessionGetOptionalParams

Parametri facoltativi

callback

ServiceCallback<ExtendedLivySessionResponse>

Callback

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

Ottiene una singola istruzione all'interno di una sessione spark.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

statementId

number

Identificatore per l'istruzione.

options

RequestOptionsBase

Parametri facoltativi

Restituisce

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

statementId

number

Identificatore per l'istruzione.

options

RequestOptionsBase

Parametri facoltativi

callback

ServiceCallback<LivyStatementResponseBody>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

statementId

number

Identificatore per l'istruzione.

callback

ServiceCallback<LivyStatementResponseBody>

Callback

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Callback

list(string, string, SparkSessionListOptionalParams)

Elencare tutte le sessioni Spark in esecuzione in un determinato pool di spark.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

options

SparkSessionListOptionalParams

Parametri facoltativi

Restituisce

Promise<SparkSessionListResponse>

Promise<Models.SparkSessionListResponse>

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

options

SparkSessionListOptionalParams

Parametri facoltativi

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Callback

listStatements(string, string, number, RequestOptionsBase)

Ottiene un elenco di istruzioni all'interno di una sessione Spark.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

RequestOptionsBase

Parametri facoltativi

Restituisce

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

RequestOptionsBase

Parametri facoltativi

callback

ServiceCallback<LivyStatementsResponseBody>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

callback

ServiceCallback<LivyStatementsResponseBody>

Callback

resetTimeout(string, string, number, RequestOptionsBase)

Invia una chiamata keep-alive alla sessione corrente per reimpostare il timeout della sessione.

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

RequestOptionsBase

Parametri facoltativi

Restituisce

Promise<RestResponse>

Prometti<msRest.RestResponse>

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

options

RequestOptionsBase

Parametri facoltativi

callback

ServiceCallback<void>

Callback

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

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

Parametri

workspaceName

string

Nome dell'area di lavoro in cui eseguire operazioni.

sparkPoolName

string

Nome del pool di spark. "ondemand" punta alla piscina ondemand.

sessionId

number

Identificatore della sessione.

callback

ServiceCallback<void>

Callback