مشاركة عبر


SparkSessionOperations interface

واجهة تمثل SparkSessionOperations.

الأساليب

cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)

إلغاء جلسة عمل Spark قيد التشغيل.

cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)

اقتل عبارة ضمن جلسة عمل.

createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)

إنشاء جلسة spark جديدة.

createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)

إنشاء عبارة داخل جلسة عمل spark.

getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)

يحصل على جلسة spark واحدة.

getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)

سرد جميع جلسات spark التي تعمل ضمن تجمع Spark معين.

getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)

الحصول على عبارة واحدة ضمن جلسة Spark.

getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)

الحصول على قائمة عبارات داخل جلسة spark.

resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)

يرسل استدعاء الاحتفاظ بالحية إلى جلسة العمل الحالية لإعادة تعيين مهلة جلسة العمل.

تفاصيل الأسلوب

cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)

إلغاء جلسة عمل Spark قيد التشغيل.

function cancelSparkSession(sessionId: number, options?: SparkSessionCancelSparkSessionOptionalParams): Promise<void>

المعلمات

sessionId

number

معرف جلسة العمل.

options
SparkSessionCancelSparkSessionOptionalParams

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

المرتجعات

Promise<void>

cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)

اقتل عبارة ضمن جلسة عمل.

function cancelSparkStatement(sessionId: number, statementId: number, options?: SparkSessionCancelSparkStatementOptionalParams): Promise<SparkStatementCancellationResult>

المعلمات

sessionId

number

معرف جلسة العمل.

statementId

number

معرف العبارة.

options
SparkSessionCancelSparkStatementOptionalParams

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

المرتجعات

createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)

إنشاء جلسة spark جديدة.

function createSparkSession(sparkSessionOptions: SparkSessionOptions, options?: SparkSessionCreateSparkSessionOptionalParams): Promise<SparkSession>

المعلمات

sparkSessionOptions
SparkSessionOptions

حمولة طلب وظيفة دفعية متوافقة مع Livy.

options
SparkSessionCreateSparkSessionOptionalParams

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

المرتجعات

Promise<SparkSession>

createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)

إنشاء عبارة داخل جلسة عمل spark.

function createSparkStatement(sessionId: number, sparkStatementOptions: SparkStatementOptions, options?: SparkSessionCreateSparkStatementOptionalParams): Promise<SparkStatement>

المعلمات

sessionId

number

معرف جلسة العمل.

sparkStatementOptions
SparkStatementOptions

حمولة طلب وظيفة دفعية متوافقة مع Livy.

options
SparkSessionCreateSparkStatementOptionalParams

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

المرتجعات

Promise<SparkStatement>

getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)

يحصل على جلسة spark واحدة.

function getSparkSession(sessionId: number, options?: SparkSessionGetSparkSessionOptionalParams): Promise<SparkSession>

المعلمات

sessionId

number

معرف جلسة العمل.

options
SparkSessionGetSparkSessionOptionalParams

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

المرتجعات

Promise<SparkSession>

getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)

سرد جميع جلسات spark التي تعمل ضمن تجمع Spark معين.

function getSparkSessions(options?: SparkSessionGetSparkSessionsOptionalParams): Promise<SparkSessionCollection>

المعلمات

options
SparkSessionGetSparkSessionsOptionalParams

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

المرتجعات

getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)

الحصول على عبارة واحدة ضمن جلسة Spark.

function getSparkStatement(sessionId: number, statementId: number, options?: SparkSessionGetSparkStatementOptionalParams): Promise<SparkStatement>

المعلمات

sessionId

number

معرف جلسة العمل.

statementId

number

معرف العبارة.

options
SparkSessionGetSparkStatementOptionalParams

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

المرتجعات

Promise<SparkStatement>

getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)

الحصول على قائمة عبارات داخل جلسة spark.

function getSparkStatements(sessionId: number, options?: SparkSessionGetSparkStatementsOptionalParams): Promise<SparkStatementCollection>

المعلمات

sessionId

number

معرف جلسة العمل.

options
SparkSessionGetSparkStatementsOptionalParams

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

المرتجعات

resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)

يرسل استدعاء الاحتفاظ بالحية إلى جلسة العمل الحالية لإعادة تعيين مهلة جلسة العمل.

function resetSparkSessionTimeout(sessionId: number, options?: SparkSessionResetSparkSessionTimeoutOptionalParams): Promise<void>

المعلمات

sessionId

number

معرف جلسة العمل.

options
SparkSessionResetSparkSessionTimeoutOptionalParams

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

المرتجعات

Promise<void>