SparkSession class

Pakiet:: @azure/synapse

Klasa reprezentująca platformę SparkSession.

Konstruktory

Tworzenie platformy SparkSession.

Metody

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Utwórz nową sesję platformy Spark.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Utwórz instrukcję w ramach sesji platformy Spark.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Anuluje uruchomioną sesję platformy Spark.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Zabij instrukcję w ramach sesji.
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)	Pobiera pojedynczą sesję platformy Spark.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Pobiera pojedynczą instrukcję w ramach sesji platformy 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)	Wyświetl listę wszystkich sesji platformy Spark uruchomionych w ramach określonej puli platformy Spark.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Pobiera listę instrukcji w ramach sesji platformy Spark.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Wysyła aktywne wywołanie do bieżącej sesji w celu zresetowania limitu czasu sesji.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Szczegóły konstruktora

SparkSession(SynapseClientContext)

Tworzenie platformy SparkSession.

new SparkSession(client: SynapseClientContext)

Parametry

client: SynapseClientContext

Odwołanie do klienta usługi.

Szczegóły metody

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

livyRequest: ExtendedLivySessionRequest

Ładunek żądania zadania wsadowego zgodnego z usługą Livy.

callback: ServiceCallback<ExtendedLivySessionResponse>

Wywołanie zwrotne

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Utwórz nową sesję platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

livyRequest: ExtendedLivySessionRequest

Ładunek żądania zadania wsadowego zgodnego z usługą Livy.

options: SparkSessionCreateOptionalParams

Parametry opcjonalne

Zwraca

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

livyRequest: ExtendedLivySessionRequest

Ładunek żądania zadania wsadowego zgodnego z usługą Livy.

options: SparkSessionCreateOptionalParams

Parametry opcjonalne

callback: ServiceCallback<ExtendedLivySessionResponse>

Wywołanie zwrotne

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

Utwórz instrukcję w ramach sesji platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

livyRequest: LivyStatementRequestBody

Ładunek żądania zadania wsadowego zgodnego z usługą Livy.

options: RequestOptionsBase

Parametry opcjonalne

Zwraca

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

livyRequest: LivyStatementRequestBody

Ładunek żądania zadania wsadowego zgodnego z usługą Livy.

options: RequestOptionsBase

Parametry opcjonalne

callback: ServiceCallback<LivyStatementResponseBody>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

livyRequest: LivyStatementRequestBody

Ładunek żądania zadania wsadowego zgodnego z usługą Livy.

callback: ServiceCallback<LivyStatementResponseBody>

Wywołanie zwrotne

deleteMethod(string, string, number, RequestOptionsBase)

Anuluje uruchomioną sesję platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: RequestOptionsBase

Parametry opcjonalne

Zwraca

Promise<RestResponse>

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

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: RequestOptionsBase

Parametry opcjonalne

callback: ServiceCallback<void>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

callback: ServiceCallback<void>

Wywołanie zwrotne

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

Zabij instrukcję w ramach sesji.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

statementId: number

Identyfikator instrukcji .

options: RequestOptionsBase

Parametry opcjonalne

Zwraca

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

statementId: number

Identyfikator instrukcji .

options: RequestOptionsBase

Parametry opcjonalne

callback: ServiceCallback<LivyStatementCancellationResponse>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

statementId: number

Identyfikator instrukcji .

callback: ServiceCallback<LivyStatementCancellationResponse>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

callback: ServiceCallback<ExtendedLivySessionResponse>

Wywołanie zwrotne

get(string, string, number, SparkSessionGetOptionalParams)

Pobiera pojedynczą sesję platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: SparkSessionGetOptionalParams

Parametry opcjonalne

Zwraca

Promise<SparkSessionGetResponse>

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

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: SparkSessionGetOptionalParams

Parametry opcjonalne

callback: ServiceCallback<ExtendedLivySessionResponse>

Wywołanie zwrotne

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

Pobiera pojedynczą instrukcję w ramach sesji platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

statementId: number

Identyfikator instrukcji .

options: RequestOptionsBase

Parametry opcjonalne

Zwraca

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

statementId: number

Identyfikator instrukcji .

options: RequestOptionsBase

Parametry opcjonalne

callback: ServiceCallback<LivyStatementResponseBody>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

statementId: number

Identyfikator instrukcji .

callback: ServiceCallback<LivyStatementResponseBody>

Wywołanie zwrotne

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Wywołanie zwrotne

list(string, string, SparkSessionListOptionalParams)

Wyświetl listę wszystkich sesji platformy Spark uruchomionych w ramach określonej puli platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

options: SparkSessionListOptionalParams

Parametry opcjonalne

Zwraca

Promise<SparkSessionListResponse>

Promise<Models.SparkSessionListResponse>

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

options: SparkSessionListOptionalParams

Parametry opcjonalne

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Wywołanie zwrotne

listStatements(string, string, number, RequestOptionsBase)

Pobiera listę instrukcji w ramach sesji platformy Spark.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: RequestOptionsBase

Parametry opcjonalne

Zwraca

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: RequestOptionsBase

Parametry opcjonalne

callback: ServiceCallback<LivyStatementsResponseBody>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

callback: ServiceCallback<LivyStatementsResponseBody>

Wywołanie zwrotne

resetTimeout(string, string, number, RequestOptionsBase)

Wysyła aktywne wywołanie do bieżącej sesji w celu zresetowania limitu czasu sesji.

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: RequestOptionsBase

Parametry opcjonalne

Zwraca

Promise<RestResponse>

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

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

options: RequestOptionsBase

Parametry opcjonalne

callback: ServiceCallback<void>

Wywołanie zwrotne

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

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

Parametry

workspaceName: string

Nazwa obszaru roboczego do wykonania operacji.

sparkPoolName: string

Nazwa puli spark. Element "ondemand" jest przeznaczony dla puli ondemand.

sessionId: number

Identyfikator sesji.

callback: ServiceCallback<void>

Wywołanie zwrotne