SparkSession class

Balíček:

@azure/synapse

Třída představující SparkSession

Konstruktory

SparkSession(SynapseClientContext)

Vytvořte SparkSession.

Metody

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Vytvořte novou relaci Sparku.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Příkaz Create v rámci relace Sparku
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Zruší spuštěnou relaci Sparku.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Ukončení příkazu v rámci relace
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)	Získá jednu relaci Sparku.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Získá jeden příkaz v rámci relace Sparku.
getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)
list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)
list(string, string, SparkSessionListOptionalParams)	Vypíše všechny relace Sparku, které jsou spuštěné v rámci konkrétního fondu sparku.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Získá seznam příkazů v relaci Sparku.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Odešle do aktuální relace aktivní volání, které resetuje časový limit relace.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Podrobnosti konstruktoru

SparkSession(SynapseClientContext)

Vytvořte SparkSession.

new SparkSession(client: SynapseClientContext)

Parametry

client

SynapseClientContext

Odkaz na klienta služby

Podrobnosti metody

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

livyRequest

ExtendedLivySessionRequest

Datová část žádosti o dávkové úlohy kompatibilní s Livy

callback

ServiceCallback<ExtendedLivySessionResponse>

Zpětné volání

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Vytvořte novou relaci Sparku.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

livyRequest

ExtendedLivySessionRequest

Datová část žádosti o dávkové úlohy kompatibilní s Livy

options

SparkSessionCreateOptionalParams

Volitelné parametry

Návraty

Promise<SparkSessionCreateResponse>

Příslib<Models.SparkSessionCreateResponse>

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

livyRequest

ExtendedLivySessionRequest

Datová část žádosti o dávkové úlohy kompatibilní s Livy

options

SparkSessionCreateOptionalParams

Volitelné parametry

callback

ServiceCallback<ExtendedLivySessionResponse>

Zpětné volání

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

Příkaz Create v rámci relace Sparku

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

livyRequest

LivyStatementRequestBody

Datová část žádosti o dávkové úlohy kompatibilní s Livy

options

RequestOptionsBase

Volitelné parametry

Návraty

Promise<SparkSessionCreateStatementResponse>

Příslib<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>)

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

livyRequest

LivyStatementRequestBody

Datová část žádosti o dávkové úlohy kompatibilní s Livy

options

RequestOptionsBase

Volitelné parametry

callback

ServiceCallback<LivyStatementResponseBody>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

livyRequest

LivyStatementRequestBody

Datová část žádosti o dávkové úlohy kompatibilní s Livy

callback

ServiceCallback<LivyStatementResponseBody>

Zpětné volání

deleteMethod(string, string, number, RequestOptionsBase)

Zruší spuštěnou relaci Sparku.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

RequestOptionsBase

Volitelné parametry

Návraty

Promise<RestResponse>

Příslib<msRest.RestResponse>

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

RequestOptionsBase

Volitelné parametry

callback

ServiceCallback<void>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

callback

ServiceCallback<void>

Zpětné volání

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

Ukončení příkazu v rámci relace

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

statementId

number

Identifikátor příkazu.

options

RequestOptionsBase

Volitelné parametry

Návraty

Promise<SparkSessionDeleteStatementResponse>

Příslib<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>)

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

statementId

number

Identifikátor příkazu.

options

RequestOptionsBase

Volitelné parametry

callback

ServiceCallback<LivyStatementCancellationResponse>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

statementId

number

Identifikátor příkazu.

callback

ServiceCallback<LivyStatementCancellationResponse>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

callback

ServiceCallback<ExtendedLivySessionResponse>

Zpětné volání

get(string, string, number, SparkSessionGetOptionalParams)

Získá jednu relaci Sparku.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

SparkSessionGetOptionalParams

Volitelné parametry

Návraty

Promise<SparkSessionGetResponse>

Příslib<Models.SparkSessionGetResponse>

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

SparkSessionGetOptionalParams

Volitelné parametry

callback

ServiceCallback<ExtendedLivySessionResponse>

Zpětné volání

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

Získá jeden příkaz v rámci relace Sparku.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

statementId

number

Identifikátor příkazu.

options

RequestOptionsBase

Volitelné parametry

Návraty

Promise<SparkSessionGetStatementResponse>

Příslib<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>)

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

statementId

number

Identifikátor příkazu.

options

RequestOptionsBase

Volitelné parametry

callback

ServiceCallback<LivyStatementResponseBody>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

statementId

number

Identifikátor příkazu.

callback

ServiceCallback<LivyStatementResponseBody>

Zpětné volání

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Zpětné volání

list(string, string, SparkSessionListOptionalParams)

Vypíše všechny relace Sparku, které jsou spuštěné v rámci konkrétního fondu sparku.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

options

SparkSessionListOptionalParams

Volitelné parametry

Návraty

Promise<SparkSessionListResponse>

Příslib<Models.SparkSessionListResponse>

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

options

SparkSessionListOptionalParams

Volitelné parametry

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Zpětné volání

listStatements(string, string, number, RequestOptionsBase)

Získá seznam příkazů v relaci Sparku.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

RequestOptionsBase

Volitelné parametry

Návraty

Promise<SparkSessionListStatementsResponse>

Příslib<Models.SparkSessionListStatementsResponse>

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

RequestOptionsBase

Volitelné parametry

callback

ServiceCallback<LivyStatementsResponseBody>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

callback

ServiceCallback<LivyStatementsResponseBody>

Zpětné volání

resetTimeout(string, string, number, RequestOptionsBase)

Odešle do aktuální relace aktivní volání, které resetuje časový limit relace.

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

RequestOptionsBase

Volitelné parametry

Návraty

Promise<RestResponse>

Příslib<msRest.RestResponse>

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

options

RequestOptionsBase

Volitelné parametry

callback

ServiceCallback<void>

Zpětné volání

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

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

Parametry

workspaceName

string

Název pracovního prostoru pro provádění operací.

sparkPoolName

string

Název fondu Spark. "ondemand" cílí na fond ondemand.

sessionId

number

Identifikátor relace.

callback

ServiceCallback<void>

Zpětné volání