Submit-AzSynapseSparkJob
Envía un trabajo de Spark de Synapse Analytics.
Sintaxis
RunSparkJobParameterSetName (valor predeterminado)
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
El cmdlet Submit-AzSynapseSparkJob envía un trabajo de Spark de Synapse Analytics.
Ejemplos
Ejemplo 1
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
Este comando envía un trabajo de Spark de Synapse Analytics.
Ejemplo 2
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
Este comando envía un trabajo de .NET de Spark de Synapse Analytics.
Ejemplo 3
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
Este comando envía un trabajo de PySpark de Synapse Analytics.
Parámetros
-CommandLineArgument
Argumentos opcionales para el trabajo. Por ejemplo, "--iteración 10000 --timeout 20s"
Propiedades de parámetro
Tipo: String [ ]
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-Configuration
Propiedades de configuración de Spark.
Propiedades de parámetro
Tipo: Hashtable
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-Confirm
Le pide confirmación antes de ejecutar el cmdlet.
Propiedades de parámetro
Tipo: SwitchParameter
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Alias: cf
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-DefaultProfile
Credenciales, cuenta, inquilino y suscripción usados para la comunicación con Azure.
Propiedades de parámetro
Tipo: IAzureContextContainer
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Alias: AzContext, AzureRmContext, AzureCredential
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-ExecutorCount
Número de ejecutores que se asignarán en el grupo de Spark especificado para el trabajo.
Propiedades de parámetro
Tipo: Int32
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-ExecutorSize
Número de núcleos y memoria que se van a usar para los ejecutores asignados en el grupo de Spark especificado para el trabajo.
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Valores aceptados: Small, Medium, Large, XLarge, XXLarge, XXXLarge
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-Language
Idioma del trabajo que se va a enviar.
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Valores aceptados: Spark, Scala, PySpark, Python, SparkDotNet, CSharp
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-MainClassName
Identificador completo o la clase principal que se encuentra en el archivo de definición principal.
Necesario para el trabajo de Spark y .NET Spark.
Por ejemplo, "org.apache.spark.examples.SparkPi"
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Alias: MainExecutableFile
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-MainDefinitionFile
Archivo principal usado para el trabajo.
Por ejemplo, "abfss://filesystem@account.dfs.core.windows.net/mySpark.jar"
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-Name
Nombre del trabajo de Spark.
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-ReferenceFile
Archivos adicionales usados como referencia en el archivo de definición principal. Lista de URI de almacenamiento separados por comas. Por ejemplo, "abfss://filesystem@account.dfs.core.windows.net/file1.txt,abfss://filesystem@account.dfs.core.windows.net/result/"
Propiedades de parámetro
Tipo: String [ ]
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-SparkPoolName
Nombre del grupo de Spark de Synapse.
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
RunSparkJobParameterSetName
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-SparkPoolObject
El objeto de entrada del grupo de Spark, normalmente se pasa a través de la canalización.
Propiedades de parámetro
Tipo: PSSynapseSparkPool
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
RunSparkJobByParentObjectParameterSet
Posición: Named
Obligatorio: True
Valor de la canalización: True
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-WhatIf
Muestra lo que sucedería si el cmdlet se ejecuta. El cmdlet no se ejecuta.
Propiedades de parámetro
Tipo: SwitchParameter
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Alias: Wi
Conjuntos de parámetros
(All)
Posición: Named
Obligatorio: False
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
-WorkspaceName
Nombre del área de trabajo de Synapse.
Propiedades de parámetro
Tipo: String
Valor predeterminado: None
Admite caracteres comodín: False
DontShow: False
Conjuntos de parámetros
RunSparkJobParameterSetName
Posición: Named
Obligatorio: True
Valor de la canalización: False
Valor de la canalización por nombre de propiedad: False
Valor de los argumentos restantes: False
CommonParameters
Este cmdlet admite los parámetros comunes: -Debug, -ErrorAction, -ErrorVariable, -InformationAction, -InformationVariable, -OutBuffer, -OutVariable, -PipelineVariable, -ProgressAction, -Verbose, -WarningAction y -WarningVariable. Para obtener más información, vea about_CommonParameters .
Salidas