SparkSession class

Пакет:: @azure/synapse

Класс, представляющий SparkSession.

Конструкторы

Создайте SparkSession.

Методы

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Создайте новый сеанс Spark.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Создайте инструкцию в сеансе Spark.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Отменяет запущенный сеанс Spark.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Убийство инструкции в сеансе.
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)	Возвращает один сеанс Spark.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Получает одну инструкцию в сеансе 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)	Перечислите все сеансы Spark, выполняемые в определенном пуле Spark.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Возвращает список инструкций в сеансе Spark.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Отправляет активный вызов текущему сеансу, чтобы сбросить время ожидания сеанса.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Сведения о конструкторе

SparkSession(SynapseClientContext)

Создайте SparkSession.

new SparkSession(client: SynapseClientContext)

Параметры

client: SynapseClientContext

Ссылка на клиент службы.

Сведения о методе

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

livyRequest: ExtendedLivySessionRequest

Полезные данные, совместимые с пакетным заданием Livy.

callback: ServiceCallback<ExtendedLivySessionResponse>

Обратный вызов

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Создайте новый сеанс Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

livyRequest: ExtendedLivySessionRequest

Полезные данные, совместимые с пакетным заданием Livy.

options: SparkSessionCreateOptionalParams

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionCreateResponse>

Обещание<Models.SparkSessionCreateResponse>

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

livyRequest: ExtendedLivySessionRequest

Полезные данные, совместимые с пакетным заданием Livy.

options: SparkSessionCreateOptionalParams

Необязательные параметры

callback: ServiceCallback<ExtendedLivySessionResponse>

Обратный вызов

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

Создайте инструкцию в сеансе Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

livyRequest: LivyStatementRequestBody

Полезные данные, совместимые с пакетным заданием Livy.

options: RequestOptionsBase

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionCreateStatementResponse>

Обещание<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>)

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

livyRequest: LivyStatementRequestBody

Полезные данные, совместимые с пакетным заданием Livy.

options: RequestOptionsBase

Необязательные параметры

callback: ServiceCallback<LivyStatementResponseBody>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

livyRequest: LivyStatementRequestBody

Полезные данные, совместимые с пакетным заданием Livy.

callback: ServiceCallback<LivyStatementResponseBody>

Обратный вызов

deleteMethod(string, string, number, RequestOptionsBase)

Отменяет запущенный сеанс Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: RequestOptionsBase

Необязательные параметры

Возвращаемое значение

Promise<RestResponse>

Обещание<msRest.RestResponse>

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: RequestOptionsBase

Необязательные параметры

callback: ServiceCallback<void>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

callback: ServiceCallback<void>

Обратный вызов

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

Убийство инструкции в сеансе.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

statementId: number

Идентификатор инструкции.

options: RequestOptionsBase

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionDeleteStatementResponse>

Обещание<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>)

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

statementId: number

Идентификатор инструкции.

options: RequestOptionsBase

Необязательные параметры

callback: ServiceCallback<LivyStatementCancellationResponse>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

statementId: number

Идентификатор инструкции.

callback: ServiceCallback<LivyStatementCancellationResponse>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

callback: ServiceCallback<ExtendedLivySessionResponse>

Обратный вызов

get(string, string, number, SparkSessionGetOptionalParams)

Возвращает один сеанс Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: SparkSessionGetOptionalParams

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionGetResponse>

Обещание<Models.SparkSessionGetResponse>

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: SparkSessionGetOptionalParams

Необязательные параметры

callback: ServiceCallback<ExtendedLivySessionResponse>

Обратный вызов

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

Получает одну инструкцию в сеансе Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

statementId: number

Идентификатор инструкции.

options: RequestOptionsBase

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionGetStatementResponse>

Обещание<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>)

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

statementId: number

Идентификатор инструкции.

options: RequestOptionsBase

Необязательные параметры

callback: ServiceCallback<LivyStatementResponseBody>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

statementId: number

Идентификатор инструкции.

callback: ServiceCallback<LivyStatementResponseBody>

Обратный вызов

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Обратный вызов

list(string, string, SparkSessionListOptionalParams)

Перечислите все сеансы Spark, выполняемые в определенном пуле Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

options: SparkSessionListOptionalParams

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionListResponse>

Обещание<Models.SparkSessionListResponse>

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

options: SparkSessionListOptionalParams

Необязательные параметры

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Обратный вызов

listStatements(string, string, number, RequestOptionsBase)

Возвращает список инструкций в сеансе Spark.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: RequestOptionsBase

Необязательные параметры

Возвращаемое значение

Promise<SparkSessionListStatementsResponse>

Обещание<Models.SparkSessionListStatementsResponse>

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: RequestOptionsBase

Необязательные параметры

callback: ServiceCallback<LivyStatementsResponseBody>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

callback: ServiceCallback<LivyStatementsResponseBody>

Обратный вызов

resetTimeout(string, string, number, RequestOptionsBase)

Отправляет активный вызов текущему сеансу, чтобы сбросить время ожидания сеанса.

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: RequestOptionsBase

Необязательные параметры

Возвращаемое значение

Promise<RestResponse>

Обещание<msRest.RestResponse>

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

options: RequestOptionsBase

Необязательные параметры

callback: ServiceCallback<void>

Обратный вызов

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

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

Параметры

workspaceName: string

Имя рабочей области для выполнения операций.

sparkPoolName: string

Имя пула Spark. "ondemand" предназначен для пула ondemand.

sessionId: number

Идентификатор сеанса.

callback: ServiceCallback<void>

Обратный вызов