SparkSession class

Paket:

@azure/synapse

Kelas yang mewakili SparkSession.

Konstruktor

SparkSession(SynapseClientContext)

Buat SparkSession.

Metode

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Buat sesi spark baru.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Buat pernyataan dalam sesi spark.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Membatalkan sesi spark yang sedang berjalan.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Membunuh pernyataan dalam sesi.
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)	Mendapatkan satu sesi spark.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Mendapatkan satu pernyataan dalam sesi 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)	Cantumkan semua sesi spark yang berjalan di bawah kumpulan spark tertentu.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Mendapatkan daftar pernyataan dalam sesi spark.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Mengirim panggilan tetap hidup ke sesi saat ini untuk mengatur ulang batas waktu sesi.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Detail Konstruktor

SparkSession(SynapseClientContext)

Buat SparkSession.

new SparkSession(client: SynapseClientContext)

Parameter

client

SynapseClientContext

Referensi ke klien layanan.

Detail Metode

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

livyRequest

ExtendedLivySessionRequest

Payload permintaan pekerjaan batch yang kompatibel dengan Livy.

callback

ServiceCallback<ExtendedLivySessionResponse>

Panggilan balik

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Buat sesi spark baru.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

livyRequest

ExtendedLivySessionRequest

Payload permintaan pekerjaan batch yang kompatibel dengan Livy.

options

SparkSessionCreateOptionalParams

Parameter opsional

Mengembalikan

Promise<SparkSessionCreateResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

livyRequest

ExtendedLivySessionRequest

Payload permintaan pekerjaan batch yang kompatibel dengan Livy.

options

SparkSessionCreateOptionalParams

Parameter opsional

callback

ServiceCallback<ExtendedLivySessionResponse>

Panggilan balik

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

Buat pernyataan dalam sesi spark.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

livyRequest

LivyStatementRequestBody

Payload permintaan pekerjaan batch yang kompatibel dengan Livy.

options

RequestOptionsBase

Parameter opsional

Mengembalikan

Promise<SparkSessionCreateStatementResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

livyRequest

LivyStatementRequestBody

Payload permintaan pekerjaan batch yang kompatibel dengan Livy.

options

RequestOptionsBase

Parameter opsional

callback

ServiceCallback<LivyStatementResponseBody>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

livyRequest

LivyStatementRequestBody

Payload permintaan pekerjaan batch yang kompatibel dengan Livy.

callback

ServiceCallback<LivyStatementResponseBody>

Panggilan balik

deleteMethod(string, string, number, RequestOptionsBase)

Membatalkan sesi spark yang sedang berjalan.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

RequestOptionsBase

Parameter opsional

Mengembalikan

Promise<RestResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

RequestOptionsBase

Parameter opsional

callback

ServiceCallback<void>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

callback

ServiceCallback<void>

Panggilan balik

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

Membunuh pernyataan dalam sesi.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

statementId

number

Pengidentifikasi untuk pernyataan tersebut.

options

RequestOptionsBase

Parameter opsional

Mengembalikan

Promise<SparkSessionDeleteStatementResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

statementId

number

Pengidentifikasi untuk pernyataan tersebut.

options

RequestOptionsBase

Parameter opsional

callback

ServiceCallback<LivyStatementCancellationResponse>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

statementId

number

Pengidentifikasi untuk pernyataan tersebut.

callback

ServiceCallback<LivyStatementCancellationResponse>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

callback

ServiceCallback<ExtendedLivySessionResponse>

Panggilan balik

get(string, string, number, SparkSessionGetOptionalParams)

Mendapatkan satu sesi spark.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

SparkSessionGetOptionalParams

Parameter opsional

Mengembalikan

Promise<SparkSessionGetResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

SparkSessionGetOptionalParams

Parameter opsional

callback

ServiceCallback<ExtendedLivySessionResponse>

Panggilan balik

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

Mendapatkan satu pernyataan dalam sesi spark.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

statementId

number

Pengidentifikasi untuk pernyataan tersebut.

options

RequestOptionsBase

Parameter opsional

Mengembalikan

Promise<SparkSessionGetStatementResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

statementId

number

Pengidentifikasi untuk pernyataan tersebut.

options

RequestOptionsBase

Parameter opsional

callback

ServiceCallback<LivyStatementResponseBody>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

statementId

number

Pengidentifikasi untuk pernyataan tersebut.

callback

ServiceCallback<LivyStatementResponseBody>

Panggilan balik

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Panggilan balik

list(string, string, SparkSessionListOptionalParams)

Cantumkan semua sesi spark yang berjalan di bawah kumpulan spark tertentu.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

options

SparkSessionListOptionalParams

Parameter opsional

Mengembalikan

Promise<SparkSessionListResponse>

Menjanjikan<Models.SparkSessionListResponse>

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

options

SparkSessionListOptionalParams

Parameter opsional

callback

ServiceCallback<ExtendedLivyListSessionResponse>

Panggilan balik

listStatements(string, string, number, RequestOptionsBase)

Mendapatkan daftar pernyataan dalam sesi spark.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

RequestOptionsBase

Parameter opsional

Mengembalikan

Promise<SparkSessionListStatementsResponse>

Menjanjikan<Models.SparkSessionListatementsResponse>

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

RequestOptionsBase

Parameter opsional

callback

ServiceCallback<LivyStatementsResponseBody>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

callback

ServiceCallback<LivyStatementsResponseBody>

Panggilan balik

resetTimeout(string, string, number, RequestOptionsBase)

Mengirim panggilan tetap hidup ke sesi saat ini untuk mengatur ulang batas waktu sesi.

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

RequestOptionsBase

Parameter opsional

Mengembalikan

Promise<RestResponse>

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

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

options

RequestOptionsBase

Parameter opsional

callback

ServiceCallback<void>

Panggilan balik

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

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

Parameter

workspaceName

string

Nama ruang kerja untuk menjalankan operasi.

sparkPoolName

string

Nama kumpulan spark. "ondemand" menargetkan kumpulan ondemand.

sessionId

number

Pengidentifikasi untuk sesi.

callback

ServiceCallback<void>

Panggilan balik