次の方法で共有


Invoke-AzSynapseSparkStatement

Synapse Analytics Spark ステートメントを呼び出します。

構文

RunSparkStatementByCodePathParameterSet (既定)

Invoke-AzSynapseSparkStatement
    -WorkspaceName <String>
    -SparkPoolName <String>
    -Language <String>
    -SessionId <Int32>
    -FilePath <String>
    [-Response]
    [-AsJob]
    [-DefaultProfile <IAzureContextContainer>]
    [-WhatIf]
    [-Confirm]
    [<CommonParameters>]

RunSparkStatementByCodeParameterSet

Invoke-AzSynapseSparkStatement
    -WorkspaceName <String>
    -SparkPoolName <String>
    -Language <String>
    -SessionId <Int32>
    -Code <String>
    [-Response]
    [-AsJob]
    [-DefaultProfile <IAzureContextContainer>]
    [-WhatIf]
    [-Confirm]
    [<CommonParameters>]

RunSparkStatementByCodeAndInputObjectParameterSet

Invoke-AzSynapseSparkStatement
    -Language <String>
    -SessionObject <PSSynapseSparkSession>
    -Code <String>
    [-SessionId <Int32>]
    [-Response]
    [-AsJob]
    [-DefaultProfile <IAzureContextContainer>]
    [-WhatIf]
    [-Confirm]
    [<CommonParameters>]

RunSparkStatementByCodePathAndInputObjectParameterSet

Invoke-AzSynapseSparkStatement
    -Language <String>
    -SessionObject <PSSynapseSparkSession>
    -FilePath <String>
    [-SessionId <Int32>]
    [-Response]
    [-AsJob]
    [-DefaultProfile <IAzureContextContainer>]
    [-WhatIf]
    [-Confirm]
    [<CommonParameters>]

説明

Invoke-AzSynapseSparkStatement コマンドレットは、Synapse Analytics Spark ステートメントを呼び出します。

例 1

$session = Start-AzSynapseSparkSession -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Name ContosoSessionName -ExecutorCount 3 -ExecutorSize Small
$session.Language = 'Spark'
$session | Invoke-AzSynapseSparkStatement -Code 'print("Hello world\n")'

これらのコマンドは、Spark セッションを開始し、パイプラインを介してインライン Spark ステートメントを呼び出します。

例 2

Invoke-AzSynapseSparkStatement -SessionId 324 -Language 'Spark' -Code 'print("Hello world\n")'

これらのコマンドは、Spark セッションを開始し、インライン Spark ステートメントを呼び出します。

例 3

$session = Start-AzSynapseSparkSession -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Name ContosoSessionName -ExecutorCount 3 -ExecutorSize Small
$session.Language = 'Spark'
$session | Invoke-AzSynapseSparkStatement -FilePath 'C:\path\to\code.sc'

これらのコマンドは、Spark セッションを開始してから、ファイル内の Spark ステートメントを呼び出します。

パラメーター

-AsJob

バックグラウンドでコマンドレットを実行する

パラメーターのプロパティ

型:SwitchParameter
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

(All)
配置:Named
必須:False
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-Code

実行コード。

パラメーターのプロパティ

型:String
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodeParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodeAndInputObjectParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-Confirm

コマンドレットを実行する前に確認を求めるメッセージが表示されます。

パラメーターのプロパティ

型:SwitchParameter
規定値:None
ワイルドカードのサポート:False
DontShow:False
Aliases:cf

パラメーター セット

(All)
配置:Named
必須:False
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-DefaultProfile

Azure との通信のために使用される資格情報、アカウント、テナント、サブスクリプションです。

パラメーターのプロパティ

型:IAzureContextContainer
規定値:None
ワイルドカードのサポート:False
DontShow:False
Aliases:AzContext, AzureRmContext, AzureCredential

パラメーター セット

(All)
配置:Named
必須:False
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-FilePath

実行コードを含むローカル ファイル パスを指定します。

パラメーターのプロパティ

型:String
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodePathParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodePathAndInputObjectParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-Language

実行コードの言語。

パラメーターのプロパティ

型:String
規定値:None
指定可能な値:Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodePathParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodeParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-Response

完全な応答を返す必要があることを示します。

パラメーターのプロパティ

型:SwitchParameter
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

(All)
配置:Named
必須:False
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-SessionId

Spark セッションの識別子。

パラメーターのプロパティ

型:Int32
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodePathParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodeParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-SessionObject

Spark セッション入力オブジェクト。通常はパイプラインを介して渡されます。

パラメーターのプロパティ

型:PSSynapseSparkSession
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodeAndInputObjectParameterSet
配置:Named
必須:True
パイプラインからの値:True
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodePathAndInputObjectParameterSet
配置:Named
必須:True
パイプラインからの値:True
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-SparkPoolName

Synapse Spark プールの名前。

パラメーターのプロパティ

型:String
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodePathParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodeParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-WhatIf

コマンドレットを実行した場合の動作を示します。 コマンドレットは実行されません。

パラメーターのプロパティ

型:SwitchParameter
規定値:None
ワイルドカードのサポート:False
DontShow:False
Aliases:ウィスコンシン

パラメーター セット

(All)
配置:Named
必須:False
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

-WorkspaceName

Synapse ワークスペースの名前。

パラメーターのプロパティ

型:String
規定値:None
ワイルドカードのサポート:False
DontShow:False

パラメーター セット

RunSparkStatementByCodePathParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False
RunSparkStatementByCodeParameterSet
配置:Named
必須:True
パイプラインからの値:False
プロパティ名別のパイプラインからの値:False
残りの引数からの値:False

CommonParameters

このコマンドレットでは、一般的なパラメーター -Debug、-ErrorAction、-ErrorVariable、-InformationAction、-InformationVariable、-OutBuffer、-OutVariable、-PipelineVariable、-ProgressAction、-Verbose、-WarningAction、-WarningVariable の各パラメーターがサポートされています。 詳細については、about_CommonParametersを参照してください。

入力

String

PSSynapseSparkSession

出力

PSSynapseExtendedSparkStatement