Submit-AzSynapseSparkJob
Synapse Analytics Spark-feladatot küld el.
Syntax
RunSparkJobParameterSetName (Alapértelmezett)
Submit-AzSynapseSparkJob
-WorkspaceName <String>
-SparkPoolName <String>
-Language <String>
-Name <String>
-MainDefinitionFile <String>
-ExecutorCount <Int32>
-ExecutorSize <String>
[-MainClassName <String>]
[-CommandLineArgument <String[]>]
[-ReferenceFile <String[]>]
[-Configuration <Hashtable>]
[-DefaultProfile <IAzureContextContainer>]
[-WhatIf]
[-Confirm]
[<CommonParameters>]
RunSparkJobByParentObjectParameterSet
Submit-AzSynapseSparkJob
-SparkPoolObject <PSSynapseSparkPool>
-Language <String>
-Name <String>
-MainDefinitionFile <String>
-ExecutorCount <Int32>
-ExecutorSize <String>
[-MainClassName <String>]
[-CommandLineArgument <String[]>]
[-ReferenceFile <String[]>]
[-Configuration <Hashtable>]
[-DefaultProfile <IAzureContextContainer>]
[-WhatIf]
[-Confirm]
[<CommonParameters>]
Description
A Submit-AzSynapseSparkJob parancsmag elküld egy Synapse Analytics Spark-feladatot.
Példák
1. példa
Submit-AzSynapseSparkJob -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Language Spark -Name WordCount_Java -MainDefinitionFile abfss://ContosoFileSystem@ContosoGen2Storage.dfs.core.windows.net/samples/java/wordcount/wordcount.jar -MainClassName WordCount -CommandLineArgument abfss://ContosoFileSystem@ContosoGen2Storage.dfs.core.windows.net/samples/java/wordcount/shakespeare.txt,abfss://ContosoFileSystem@ContosoGen2Storage.dfs.core.windows.net/samples/java/wordcount/result/ -ExecutorCount 2 -ExecutorSize Small
Ez a parancs elküld egy Synapse Analytics Spark-feladatot.
2. példa
Submit-AzSynapseSparkJob -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Language SparkDotNet -Name WordCount_Dotnet -MainDefinitionFile abfss://ContosoFileSystem@ContosoGen2Storage.dfs.core.windows.net/samples/dotnet/wordcount/wordcount.zip -MainExecutableFile WordCount -CommandLineArgument abfss://ContosoFileSystem@ContosoGen2Storage.dfs.core.windows.net/samples/dotnet/wordcount/shakespeare.txt,abfss://ContosoFileSystem@ContosoGen2Storage.dfs.core.windows.net/samples/dotnet/wordcount/result -ExecutorCount 2 -ExecutorSize Small
Ez a parancs elküld egy Synapse Analytics Spark .NET-feladatot.
3. példa
Submit-AzSynapseSparkJob -WorkspaceName ContosoWorkspace -SparkPoolName ContosoSparkPool -Language PySpark -Name WordCount_Python -MainDefinitionFile abfss://ContosoFileSystem@ContosoGen2Storage.blob.core.windows.net/samples/python/wordcount/wordcount.py -CommandLineArgument abfss://ContosoFileSystem@ContosoGen2Storage.blob.core.windows.net/samples/python/wordcount/shakespeare.txt,abfss://ContosoFileSystem@ContosoGen2Storage.blob.core.windows.net/samples/python/wordcount/result/ -ExecutorCount 2 -ExecutorSize Small
Ez a parancs elküld egy Synapse Analytics PySpark-feladatot.
Paraméterek
-CommandLineArgument
A feladat nem kötelező argumentumai. pl. "--iteráció 10000 --timeout 20s"
Paramétertulajdonságok
Típus: String [ ]
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-Configuration
Spark-konfiguráció tulajdonságai.
Paramétertulajdonságok
Típus: Hashtable
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-Confirm
Megerősítést kér a parancsmag futtatása előtt.
Paramétertulajdonságok
Típus: SwitchParameter
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Aliasok: Cf
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-DefaultProfile
Az Azure-ral való kommunikációhoz használt hitelesítő adatok, fiók, bérlő és előfizetés.
Paramétertulajdonságok
Típus: IAzureContextContainer
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Aliasok: AzContext, AzureRmContext, AzureCredential
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-ExecutorCount
A feladathoz megadott Spark-készletben lefoglalandó végrehajtók száma.
Paramétertulajdonságok
Típus: Int32
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-ExecutorSize
A feladathoz megadott Spark-készletben lefoglalt végrehajtókhoz használandó mag és memória száma.
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Elfogadott értékek: Small, Medium, Large, XLarge, XXLarge, XXXLarge
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-Language
A beküldendő feladat nyelve.
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Elfogadott értékek: Spark, Scala, PySpark, Python, SparkDotNet, CSharp
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-MainClassName
A teljes azonosító vagy a fő definíciós fájlban található főosztály.
A Spark és a .NET Spark-feladathoz szükséges.
pl. "org.apache.spark.examples.SparkPi"
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Aliasok: MainExecutableFile
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-MainDefinitionFile
A feladathoz használt fő fájl.
pl. "abfss://filesystem@account.dfs.core.windows.net/mySpark.jar"
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-Name
A Spark-feladat neve.
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-ReferenceFile
A fő definíciós fájlban hivatkozásra használt további fájlok. Vesszővel tagolt tárterület URI-listája. pl. "abfss://filesystem@account.dfs.core.windows.net/file1.txt,abfss://filesystem@account.dfs.core.windows.net/result/"
Paramétertulajdonságok
Típus: String [ ]
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-SparkPoolName
A Synapse Spark-készlet neve.
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
RunSparkJobParameterSetName
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-SparkPoolObject
Spark-készlet bemeneti objektuma, amely általában áthalad a folyamaton.
Paramétertulajdonságok
Típus: PSSynapseSparkPool
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
RunSparkJobByParentObjectParameterSet
Position: Named
Kötelező: True
Folyamatból származó érték: True
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-WhatIf
Megjeleníti, mi történne, ha a parancsmag futna. A parancsmag nem fut.
Paramétertulajdonságok
Típus: SwitchParameter
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Aliasok: Wi
Paraméterkészletek
(All)
Position: Named
Kötelező: False
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
-WorkspaceName
A Synapse-munkaterület neve.
Paramétertulajdonságok
Típus: String
Alapértelmezett érték: None
Támogatja a helyettesítő karaktereket: False
DontShow: False
Paraméterkészletek
RunSparkJobParameterSetName
Position: Named
Kötelező: True
Folyamatból származó érték: False
Folyamatból származó érték tulajdonságnév alapján: False
Fennmaradó argumentumokból származó érték: False
CommonParameters
Ez a parancsmag a következő gyakori paramétereket támogatja: -Debug, -ErrorAction, -ErrorVariable, -InformationAction, -InformationVariable, -OutBuffer, -OutVariable, -PipelineVariable, -ProgressAction, -Verbose, -WarningAction és -WarningVariable. További információért lásd about_CommonParameters .
Kimenetek