SparkSessionOperations interface
واجهة تمثل SparkSessionOperations.
الأساليب
تفاصيل الأسلوب
cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)
إلغاء جلسة عمل Spark قيد التشغيل.
function cancelSparkSession(sessionId: number, options?: SparkSessionCancelSparkSessionOptionalParams): Promise<void>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
معلمات الخيارات.
المرتجعات
Promise<void>
cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)
اقتل عبارة ضمن جلسة عمل.
function cancelSparkStatement(sessionId: number, statementId: number, options?: SparkSessionCancelSparkStatementOptionalParams): Promise<SparkStatementCancellationResult>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
- statementId
-
number
معرف العبارة.
معلمات الخيارات.
المرتجعات
Promise<SparkStatementCancellationResult>
createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)
إنشاء جلسة spark جديدة.
function createSparkSession(sparkSessionOptions: SparkSessionOptions, options?: SparkSessionCreateSparkSessionOptionalParams): Promise<SparkSession>
المعلمات
- sparkSessionOptions
- SparkSessionOptions
حمولة طلب وظيفة دفعية متوافقة مع Livy.
معلمات الخيارات.
المرتجعات
Promise<SparkSession>
createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)
إنشاء عبارة داخل جلسة عمل spark.
function createSparkStatement(sessionId: number, sparkStatementOptions: SparkStatementOptions, options?: SparkSessionCreateSparkStatementOptionalParams): Promise<SparkStatement>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
- sparkStatementOptions
- SparkStatementOptions
حمولة طلب وظيفة دفعية متوافقة مع Livy.
معلمات الخيارات.
المرتجعات
Promise<SparkStatement>
getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)
يحصل على جلسة spark واحدة.
function getSparkSession(sessionId: number, options?: SparkSessionGetSparkSessionOptionalParams): Promise<SparkSession>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
معلمات الخيارات.
المرتجعات
Promise<SparkSession>
getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)
سرد جميع جلسات spark التي تعمل ضمن تجمع Spark معين.
function getSparkSessions(options?: SparkSessionGetSparkSessionsOptionalParams): Promise<SparkSessionCollection>
المعلمات
معلمات الخيارات.
المرتجعات
Promise<SparkSessionCollection>
getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)
الحصول على عبارة واحدة ضمن جلسة Spark.
function getSparkStatement(sessionId: number, statementId: number, options?: SparkSessionGetSparkStatementOptionalParams): Promise<SparkStatement>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
- statementId
-
number
معرف العبارة.
معلمات الخيارات.
المرتجعات
Promise<SparkStatement>
getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)
الحصول على قائمة عبارات داخل جلسة spark.
function getSparkStatements(sessionId: number, options?: SparkSessionGetSparkStatementsOptionalParams): Promise<SparkStatementCollection>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
معلمات الخيارات.
المرتجعات
Promise<SparkStatementCollection>
resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)
يرسل استدعاء الاحتفاظ بالحية إلى جلسة العمل الحالية لإعادة تعيين مهلة جلسة العمل.
function resetSparkSessionTimeout(sessionId: number, options?: SparkSessionResetSparkSessionTimeoutOptionalParams): Promise<void>
المعلمات
- sessionId
-
number
معرف جلسة العمل.
معلمات الخيارات.
المرتجعات
Promise<void>