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

Invoke-AzSynapseSparkStatement

参考

模块:: Az.Synapse

调用 Synapse Analytics Spark 语句。

语法

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

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

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

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

说明

Invoke-AzSynapseSparkStatement cmdlet 调用 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

在后台运行 cmdlet

类型:	SwitchParameter
Position:	Named
默认值:	None
必需:	False
接受管道输入:	False
接受通配符:	False

-Code

执行代码。

类型:	String
Position:	Named
默认值:	None
必需:	True
接受管道输入:	False
接受通配符:	False

-Confirm

提示你在运行 cmdlet 之前进行确认。

类型:	SwitchParameter
别名:	cf
Position:	Named
默认值:	None
必需:	False
接受管道输入:	False
接受通配符:	False

-DefaultProfile

用于与 Azure 通信的凭据、帐户、租户和订阅。

类型:	IAzureContextContainer
别名:	AzContext, AzureRmContext, AzureCredential
Position:	Named
默认值:	None
必需:	False
接受管道输入:	False
接受通配符:	False

-FilePath

指定包含执行代码的本地文件路径。

类型:	String
Position:	Named
默认值:	None
必需:	True
接受管道输入:	False
接受通配符:	False

-Language

执行代码的语言。

类型:	String
接受的值:	Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL, Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
Position:	Named
默认值:	None
必需:	True
接受管道输入:	False
接受通配符:	False

-Response

指示应返回完整响应。

类型:	SwitchParameter
Position:	Named
默认值:	None
必需:	False
接受管道输入:	False
接受通配符:	False

-SessionId

Spark 会话的标识符。

类型:	Int32
Position:	Named
默认值:	None
必需:	True
接受管道输入:	False
接受通配符:	False

-SessionObject

Spark 会话输入对象，通常通过管道传递。

类型:	PSSynapseSparkSession
Position:	Named
默认值:	None
必需:	True
接受管道输入:	True
接受通配符:	False

-SparkPoolName

Synapse Spark 池的名称。

类型:	String
Position:	Named
默认值:	None
必需:	True
接受管道输入:	False
接受通配符:	False

-WhatIf

显示运行该 cmdlet 时会发生什么情况。 cmdlet 未运行。

类型:	SwitchParameter
别名:	wi
Position:	Named
默认值:	None
必需:	False
接受管道输入:	False
接受通配符:	False

-WorkspaceName

Synapse 工作区的名称。

类型:	String
Position:	Named
默认值:	None
必需:	True
接受管道输入:	False
接受通配符:	False

输入

String

PSSynapseSparkSession

输出

PSSynapseExtendedSparkStatement

通过