次の方法で共有


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 セッション内の 1 つのステートメントを取得します。

GetSparkStatementAsync(Int32, Int32, CancellationToken)

Spark セッション内の 1 つのステートメントを取得します。

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 サービス クライアント。

適用対象