SparkSession class

فئة تمثل SparkSession.

المنشئون

SparkSession(SynapseClientContext)

إنشاء 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

المعلمات الاختيارية

المرتجعات

وعد<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

المعلمات الاختيارية

المرتجعات

وعد<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

المعلمات الاختيارية

المرتجعات

وعد<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

المعلمات الاختيارية

المرتجعات

وعد<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

المعلمات الاختيارية

المرتجعات

وعد<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

المعلمات الاختيارية

المرتجعات

وعد<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

المعلمات الاختيارية

المرتجعات

وعد<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>

رد الاتصال