你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

SparkSessionClient 类

定义

SparkSession 服务客户端。

public class SparkSessionClient
type SparkSessionClient = class
Public Class SparkSessionClient
继承
SparkSessionClient

构造函数

SparkSessionClient()

初始化用于模拟的 SparkSessionClient 的新实例。

SparkSessionClient(Uri, String, TokenCredential, String, SparkClientOptions)

初始化 SparkSessionClient 的新实例。

方法

CancelSparkSession(Int32, CancellationToken)

取消正在运行的 Spark 会话。

CancelSparkSessionAsync(Int32, CancellationToken)

取消正在运行的 Spark 会话。

CancelSparkStatement(Int32, Int32, CancellationToken)

终止会话中的语句。

CancelSparkStatementAsync(Int32, Int32, CancellationToken)

终止会话中的语句。

GetSparkSession(Int32, Nullable<Boolean>, CancellationToken)

获取单个 Spark 会话。

GetSparkSessionAsync(Int32, Nullable<Boolean>, CancellationToken)

获取单个 Spark 会话。

GetSparkSessions(Nullable<Int32>, Nullable<Int32>, Nullable<Boolean>, CancellationToken)

列出在特定 Spark 池下运行的所有 Spark 会话。

GetSparkSessionsAsync(Nullable<Int32>, Nullable<Int32>, Nullable<Boolean>, CancellationToken)

列出在特定 Spark 池下运行的所有 Spark 会话。

GetSparkStatement(Int32, Int32, CancellationToken)

获取 Spark 会话中的单个语句。

GetSparkStatementAsync(Int32, Int32, CancellationToken)

获取 Spark 会话中的单个语句。

GetSparkStatements(Int32, CancellationToken)

获取 Spark 会话中的语句列表。

GetSparkStatementsAsync(Int32, CancellationToken)

获取 Spark 会话中的语句列表。

ResetSparkSessionTimeout(Int32, CancellationToken)

向当前会话发送保持活动状态调用以重置会话超时。

ResetSparkSessionTimeoutAsync(Int32, CancellationToken)

向当前会话发送保持活动状态调用以重置会话超时。

StartCreateSparkSession(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

SparkSession 服务客户端。

StartCreateSparkSessionAsync(SparkSessionOptions, Nullable<Boolean>, CancellationToken)

SparkSession 服务客户端。

StartCreateSparkStatement(Int32, SparkStatementOptions, CancellationToken)

SparkSession 服务客户端。

StartCreateSparkStatementAsync(Int32, SparkStatementOptions, CancellationToken)

SparkSession 服务客户端。

适用于