SparkSession class

Paket:

@azure/synapse

Klasse, die eine SparkSession darstellt.

Konstruktoren

SparkSession(SynapseClientContext)

Erstellen Sie eine SparkSession.

Methoden

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Neue Spark-Sitzung erstellen.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Erstellen sie eine Anweisung innerhalb einer Spark-Sitzung.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Bricht eine laufende Spark-Sitzung ab.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Beenden sie eine Anweisung innerhalb einer Sitzung.
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)	Ruft eine einzelne Spark-Sitzung ab.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Ruft eine einzelne Anweisung innerhalb einer Spark-Sitzung ab.
getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)
list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)
list(string, string, SparkSessionListOptionalParams)	Auflisten aller Spark-Sitzungen, die unter einem bestimmten Sparkpool ausgeführt werden.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Ruft eine Liste von Anweisungen innerhalb einer Spark-Sitzung ab.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Sendet einen Keep Alive-Aufruf an die aktuelle Sitzung, um das Sitzungstimeout zurückzusetzen.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Details zum Konstruktor

SparkSession(SynapseClientContext)

Erstellen Sie eine SparkSession.

new SparkSession(client: SynapseClientContext)

Parameter

client

SynapseClientContext

Verweisen auf den Dienstclient.

Details zur Methode

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

livyRequest

ExtendedLivySessionRequest

Livy kompatible Batchauftragsanforderung Nutzlast.

callback

ServiceCallback<ExtendedLivySessionResponse>

Der Rückruf

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Neue Spark-Sitzung erstellen.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

livyRequest

ExtendedLivySessionRequest

Livy kompatible Batchauftragsanforderung Nutzlast.

options

SparkSessionCreateOptionalParams

Die optionalen Parameter

Gibt zurück

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

livyRequest

ExtendedLivySessionRequest

Livy kompatible Batchauftragsanforderung Nutzlast.

options

SparkSessionCreateOptionalParams

Die optionalen Parameter

callback

ServiceCallback<ExtendedLivySessionResponse>

Der Rückruf

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

Erstellen sie eine Anweisung innerhalb einer Spark-Sitzung.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

livyRequest

LivyStatementRequestBody

Livy kompatible Batchauftragsanforderung Nutzlast.

options

RequestOptionsBase

Die optionalen Parameter

Gibt zurück

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

livyRequest

LivyStatementRequestBody

Livy kompatible Batchauftragsanforderung Nutzlast.

options

RequestOptionsBase

Die optionalen Parameter

callback

ServiceCallback<LivyStatementResponseBody>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

livyRequest

LivyStatementRequestBody

Livy kompatible Batchauftragsanforderung Nutzlast.

callback

ServiceCallback<LivyStatementResponseBody>

Der Rückruf

deleteMethod(string, string, number, RequestOptionsBase)

Bricht eine laufende Spark-Sitzung ab.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

RequestOptionsBase

Die optionalen Parameter

Gibt zurück

Promise<RestResponse>

Zusage<msRest.RestResponse>

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

RequestOptionsBase

Die optionalen Parameter

callback

ServiceCallback<void>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

callback

ServiceCallback<void>

Der Rückruf

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

Beenden sie eine Anweisung innerhalb einer Sitzung.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

statementId

number

Bezeichner für die Anweisung.

options

RequestOptionsBase

Die optionalen Parameter

Gibt zurück

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

statementId

number

Bezeichner für die Anweisung.

options

RequestOptionsBase

Die optionalen Parameter

callback

ServiceCallback<LivyStatementCancellationResponse>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

statementId

number

Bezeichner für die Anweisung.

callback

ServiceCallback<LivyStatementCancellationResponse>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

callback

ServiceCallback<ExtendedLivySessionResponse>

Der Rückruf

get(string, string, number, SparkSessionGetOptionalParams)

Ruft eine einzelne Spark-Sitzung ab.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

SparkSessionGetOptionalParams

Die optionalen Parameter

Gibt zurück

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

SparkSessionGetOptionalParams

Die optionalen Parameter

callback

ServiceCallback<ExtendedLivySessionResponse>

Der Rückruf

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

Ruft eine einzelne Anweisung innerhalb einer Spark-Sitzung ab.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

statementId

number

Bezeichner für die Anweisung.

options

RequestOptionsBase

Die optionalen Parameter

Gibt zurück

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

statementId

number

Bezeichner für die Anweisung.

options

RequestOptionsBase

Die optionalen Parameter

callback

ServiceCallback<LivyStatementResponseBody>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

statementId

number

Bezeichner für die Anweisung.

callback

ServiceCallback<LivyStatementResponseBody>

Der Rückruf

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Der Rückruf

list(string, string, SparkSessionListOptionalParams)

Auflisten aller Spark-Sitzungen, die unter einem bestimmten Sparkpool ausgeführt werden.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

options

SparkSessionListOptionalParams

Die optionalen Parameter

Gibt zurück

Promise<SparkSessionListResponse>

Promise<Models.SparkSessionListResponse>

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

options

SparkSessionListOptionalParams

Die optionalen Parameter

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Der Rückruf

listStatements(string, string, number, RequestOptionsBase)

Ruft eine Liste von Anweisungen innerhalb einer Spark-Sitzung ab.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

RequestOptionsBase

Die optionalen Parameter

Gibt zurück

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

RequestOptionsBase

Die optionalen Parameter

callback

ServiceCallback<LivyStatementsResponseBody>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

callback

ServiceCallback<LivyStatementsResponseBody>

Der Rückruf

resetTimeout(string, string, number, RequestOptionsBase)

Sendet einen Keep Alive-Aufruf an die aktuelle Sitzung, um das Sitzungstimeout zurückzusetzen.

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

RequestOptionsBase

Die optionalen Parameter

Gibt zurück

Promise<RestResponse>

Zusage<msRest.RestResponse>

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

options

RequestOptionsBase

Die optionalen Parameter

callback

ServiceCallback<void>

Der Rückruf

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

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

Parameter

workspaceName

string

Der Name des Arbeitsbereichs zum Ausführen von Vorgängen.

sparkPoolName

string

Name des Sparkpools. "ondemand" zielt auf den Ondemand-Pool ab.

sessionId

number

Bezeichner für die Sitzung.

callback

ServiceCallback<void>

Der Rückruf