Invoke-AzSynapseSparkStatement
Roept een Synapse Analytics Spark-instructie aan.
Syntax
RunSparkStatementByCodePathParameterSet (Standaard)
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>]
Invoke-AzSynapseSparkStatement
-Language <String>
-SessionObject <PSSynapseSparkSession>
-Code <String>
[-SessionId <Int32>]
[-Response]
[-AsJob]
[-DefaultProfile <IAzureContextContainer>]
[-WhatIf]
[-Confirm]
[<CommonParameters>]
Invoke-AzSynapseSparkStatement
-Language <String>
-SessionObject <PSSynapseSparkSession>
-FilePath <String>
[-SessionId <Int32>]
[-Response]
[-AsJob]
[-DefaultProfile <IAzureContextContainer>]
[-WhatIf]
[-Confirm]
[<CommonParameters>]
Description
De cmdlet Invoke-AzSynapseSparkStatement roept een Synapse Analytics Spark-instructie aan.
Voorbeelden
Voorbeeld 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")'
Met deze opdrachten start u een Spark-sessie en roept u vervolgens een inline Spark-instructie aan via de pijplijn.
Voorbeeld 2
Invoke-AzSynapseSparkStatement -SessionId 324 -Language 'Spark' -Code 'print("Hello world\n")'
Met deze opdrachten start u een Spark-sessie en roept u vervolgens een inline Spark-instructie aan.
Voorbeeld 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'
Met deze opdrachten start u een Spark-sessie en roept u vervolgens Spark-instructies in een bestand aan.
Parameters
-AsJob
Cmdlet op de achtergrond uitvoeren
Parametereigenschappen
Type: SwitchParameter
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
(All)
Position: Named
Verplicht: False
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-Code
De uitvoeringscode.
Parametereigenschappen
Type: String
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
RunSparkStatementByCodeParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodeAndInputObjectParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-Confirm
Voordat u de cmdlet uitvoert, vraagt het systeem om bevestiging.
Parametereigenschappen
Type: SwitchParameter
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Aliassen: Cf
Parametersets
(All)
Position: Named
Verplicht: False
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-DefaultProfile
De referenties, accounts, tenants en abonnementen die worden gebruikt voor communicatie met Azure.
Parametereigenschappen
Type: IAzureContextContainer
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Aliassen: AzContext, AzureRmContext, AzureCredential
Parametersets
(All)
Position: Named
Verplicht: False
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-FilePath
Hiermee geeft u een lokaal bestandspad op dat de uitvoeringscode bevat.
Parametereigenschappen
Type: String
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
RunSparkStatementByCodePathParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodePathAndInputObjectParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-Language
Taal van de uitvoeringscode.
Parametereigenschappen
Type: String
Default value: None
Geaccepteerde waarden: Spark, Scala, PySpark, Python, SparkDotNet, CSharp, SQL
Ondersteunt jokertekens: False
DontShow: False
Parametersets
RunSparkStatementByCodePathParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodeParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-Response
Geeft aan dat het volledige antwoord moet worden geretourneerd.
Parametereigenschappen
Type: SwitchParameter
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
(All)
Position: Named
Verplicht: False
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-SessionId
Id van Spark-sessie.
Parametereigenschappen
Type: Int32
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
RunSparkStatementByCodePathParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodeParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-SessionObject
Spark-sessieinvoerobject, meestal doorgegeven via de pijplijn.
Parametereigenschappen
Parametersets
RunSparkStatementByCodeAndInputObjectParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: True
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodePathAndInputObjectParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: True
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-SparkPoolName
Naam van Synapse Spark-pool.
Parametereigenschappen
Type: String
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
RunSparkStatementByCodePathParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodeParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-WhatIf
Toont wat er zou gebeuren wanneer de cmdlet wordt uitgevoerd. De cmdlet wordt niet uitgevoerd.
Parametereigenschappen
Type: SwitchParameter
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Aliassen: Wi
Parametersets
(All)
Position: Named
Verplicht: False
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
-WorkspaceName
Naam van Synapse-werkruimte.
Parametereigenschappen
Type: String
Default value: None
Ondersteunt jokertekens: False
DontShow: False
Parametersets
RunSparkStatementByCodePathParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
RunSparkStatementByCodeParameterSet
Position: Named
Verplicht: True
Waarde uit pijplijn: False
Waarde uit pijplijn op eigenschapsnaam: False
Waarde van resterende argumenten: False
CommonParameters
Deze cmdlet ondersteunt de algemene parameters: -Debug, -ErrorAction, -ErrorVariable, -InformationAction, -InformationVariable, -OutBuffer, -OutVariable, -PipelineVariable, -ProgressAction, -Verbose, -WarningAction en -WarningVariable. Zie about_CommonParameters voor meer informatie.
Uitvoerwaarden