SparkSession class

Paket:: @azure/synapse

SparkSession'ı temsil eden sınıf.

Oluşturucular

SparkSession oluşturma.

Yöntemler

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Yeni Spark oturumu oluşturun.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Spark oturumunda deyim oluşturma.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Çalışan spark oturumlarını iptal eder.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Oturum içinde bir deyimi sonlandırma.
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)	Tek bir Spark oturumu alır.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Spark oturumu içinde tek bir deyim alır.
getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)
list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)
list(string, string, SparkSessionListOptionalParams)	Belirli bir spark havuzu altında çalışan tüm spark oturumlarını listeleyin.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Spark oturumundaki deyimlerin listesini alır.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Oturum zaman aşımını sıfırlamak için geçerli oturuma canlı tutma çağrısı gönderir.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Oluşturucu Ayrıntıları

SparkSession(SynapseClientContext)

SparkSession oluşturma.

new SparkSession(client: SynapseClientContext)

Parametreler

client: SynapseClientContext

Hizmet istemcisine başvuru.

Yöntem Ayrıntıları

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

livyRequest: ExtendedLivySessionRequest

Livy uyumlu toplu iş isteği yükü.

callback: ServiceCallback<ExtendedLivySessionResponse>

Geri çağırma

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Yeni Spark oturumu oluşturun.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

livyRequest: ExtendedLivySessionRequest

Livy uyumlu toplu iş isteği yükü.

options: SparkSessionCreateOptionalParams

İsteğe bağlı parametreler

Döndürülenler

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

livyRequest: ExtendedLivySessionRequest

Livy uyumlu toplu iş isteği yükü.

options: SparkSessionCreateOptionalParams

İsteğe bağlı parametreler

callback: ServiceCallback<ExtendedLivySessionResponse>

Geri çağırma

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

Spark oturumunda deyim oluşturma.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

livyRequest: LivyStatementRequestBody

Livy uyumlu toplu iş isteği yükü.

options: RequestOptionsBase

İsteğe bağlı parametreler

Döndürülenler

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

livyRequest: LivyStatementRequestBody

Livy uyumlu toplu iş isteği yükü.

options: RequestOptionsBase

İsteğe bağlı parametreler

callback: ServiceCallback<LivyStatementResponseBody>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

livyRequest: LivyStatementRequestBody

Livy uyumlu toplu iş isteği yükü.

callback: ServiceCallback<LivyStatementResponseBody>

Geri çağırma

deleteMethod(string, string, number, RequestOptionsBase)

Çalışan spark oturumlarını iptal eder.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

Döndürülenler

Promise<RestResponse>

promise<msRest.RestResponse>

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

callback: ServiceCallback<void>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

callback: ServiceCallback<void>

Geri çağırma

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

Oturum içinde bir deyimi sonlandırma.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

statementId: number

Deyiminin tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

Döndürülenler

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

statementId: number

Deyiminin tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

callback: ServiceCallback<LivyStatementCancellationResponse>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

statementId: number

Deyiminin tanımlayıcısı.

callback: ServiceCallback<LivyStatementCancellationResponse>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

callback: ServiceCallback<ExtendedLivySessionResponse>

Geri çağırma

get(string, string, number, SparkSessionGetOptionalParams)

Tek bir Spark oturumu alır.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: SparkSessionGetOptionalParams

İsteğe bağlı parametreler

Döndürülenler

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: SparkSessionGetOptionalParams

İsteğe bağlı parametreler

callback: ServiceCallback<ExtendedLivySessionResponse>

Geri çağırma

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

Spark oturumu içinde tek bir deyim alır.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

statementId: number

Deyiminin tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

Döndürülenler

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

statementId: number

Deyiminin tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

callback: ServiceCallback<LivyStatementResponseBody>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

statementId: number

Deyiminin tanımlayıcısı.

callback: ServiceCallback<LivyStatementResponseBody>

Geri çağırma

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Geri çağırma

list(string, string, SparkSessionListOptionalParams)

Belirli bir spark havuzu altında çalışan tüm spark oturumlarını listeleyin.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

options: SparkSessionListOptionalParams

İsteğe bağlı parametreler

Döndürülenler

Promise<SparkSessionListResponse>

Promise<Models.SparkSessionListResponse>

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

options: SparkSessionListOptionalParams

İsteğe bağlı parametreler

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Geri çağırma

listStatements(string, string, number, RequestOptionsBase)

Spark oturumundaki deyimlerin listesini alır.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

Döndürülenler

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

callback: ServiceCallback<LivyStatementsResponseBody>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

callback: ServiceCallback<LivyStatementsResponseBody>

Geri çağırma

resetTimeout(string, string, number, RequestOptionsBase)

Oturum zaman aşımını sıfırlamak için geçerli oturuma canlı tutma çağrısı gönderir.

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

Döndürülenler

Promise<RestResponse>

promise<msRest.RestResponse>

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

options: RequestOptionsBase

İsteğe bağlı parametreler

callback: ServiceCallback<void>

Geri çağırma

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

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

Parametreler

workspaceName: string

İşlemlerin yürütülecek çalışma alanının adı.

sparkPoolName: string

Spark havuzunun adı. "ondemand" ondemand havuzunu hedefler.

sessionId: number

Oturumun tanımlayıcısı.

callback: ServiceCallback<void>

Geri çağırma