Invoke-AzSynapseSparkStatement

Referência

Módulo:: Az.Synapse

Invoca uma instrução Synapse Analytics Spark.

Sintaxe

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>]

Description

O cmdlet Invoke-AzSynapseSparkStatement invoca uma instrução Synapse Analytics Spark.

Exemplos

Exemplo 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")'

Esses comandos iniciam uma sessão do Spark e, em seguida, invocam uma instrução Spark embutida através do pipeline.

Exemplo 2

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

Esses comandos iniciam uma sessão do Spark e, em seguida, invocam uma instrução Spark embutida.

Exemplo 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'

Esses comandos iniciam uma sessão do Spark e, em seguida, invocam instruções do Spark em um arquivo.

Parâmetros

-AsJob

Executar cmdlet em segundo plano

Tipo:	SwitchParameter
Position:	Named
Default value:	None
Necessário:	False
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-Code

O código de execução.

Tipo:	String
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-Confirm

Solicita a sua confirmação antes de executar o cmdlet.

Tipo:	SwitchParameter
Aliases:	cf
Position:	Named
Default value:	None
Necessário:	False
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-DefaultProfile

As credenciais, a conta, o locatário e a assinatura usados para comunicação com o Azure.

Tipo:	IAzureContextContainer
Aliases:	AzContext, AzureRmContext, AzureCredential
Position:	Named
Default value:	None
Necessário:	False
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-FilePath

Especifica um caminho de arquivo local que contém o código de execução.

Tipo:	String
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-Language

Idioma do código de execução.

Tipo:	String
Valores aceites:	Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL, Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-Response

Indica que a resposta completa deve ser devolvida.

Tipo:	SwitchParameter
Position:	Named
Default value:	None
Necessário:	False
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-SessionId

Identificador da sessão do Spark.

Tipo:	Int32
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-SessionObject

Objeto de entrada de sessão de faísca, geralmente passado pelo pipeline.

Tipo:	PSSynapseSparkSession
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	True
Aceitar carateres universais:	False

-SparkPoolName

Nome da piscina Synapse Spark.

Tipo:	String
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-WhatIf

Apresenta o que aconteceria mediante a execução do cmdlet. O cmdlet não é executado.

Tipo:	SwitchParameter
Aliases:	wi
Position:	Named
Default value:	None
Necessário:	False
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

-WorkspaceName

Nome do espaço de trabalho Sinapse.

Tipo:	String
Position:	Named
Default value:	None
Necessário:	True
Aceitar entrada de pipeline:	False
Aceitar carateres universais:	False

Entradas

String

PSSynapseSparkSession

Saídas

PSSynapseExtendedSparkStatement

Partilhar via