az synapse spark job

  • Odwołanie

Zarządzanie zadaniami wsadowymi usługi Synapse Spark.

Polecenia

az synapse spark job cancel

Anuluj zadanie platformy Spark.
az synapse spark job list

Wyświetl listę wszystkich zadań platformy Spark.
az synapse spark job show

Pobieranie zadania platformy Spark.
az synapse spark job submit

Prześlij zadanie platformy Spark.

az synapse spark job cancel

Edytuj

Anuluj zadanie platformy Spark.

az synapse spark job cancel --livy-id
                            --spark-pool-name
                            --workspace-name
                            [--yes]

Przykłady

Anuluj zadanie platformy Spark.

az synapse spark job cancel --livy-id 1 --workspace-name testsynapseworkspace --spark-pool-name testsparkpool

Parametry wymagane

--livy-id

Identyfikator zadania platformy Spark.

--spark-pool-name

Nazwa puli Spark.

--workspace-name

Nazwa obszaru roboczego.

Parametry opcjonalne

--yes -y

Nie monituj o potwierdzenie.

az synapse spark job list

Edytuj

Wyświetl listę wszystkich zadań platformy Spark.

az synapse spark job list --spark-pool-name
                          --workspace-name
                          [--from-index]
                          [--size]

Przykłady

Wyświetl listę wszystkich zadań platformy Spark.

az synapse spark job list --workspace-name testsynapseworkspace --spark-pool-name testsparkpool

Parametry wymagane

--spark-pool-name

Nazwa puli Spark.

--workspace-name

Nazwa obszaru roboczego.

Parametry opcjonalne

--from-index

Opcjonalny parametr określający, od którego indeksu powinna zaczynać się lista.

--size

Rozmiar zwróconej listy. Domyślnie jest to 20 i jest to maksymalna wartość.

az synapse spark job show

Edytuj

Pobieranie zadania platformy Spark.

az synapse spark job show --livy-id
                          --spark-pool-name
                          --workspace-name

Przykłady

Pobieranie zadania platformy Spark.

az synapse spark job show --livy-id 1 --workspace-name testsynapseworkspace --spark-pool-name testsparkpool

Parametry wymagane

--livy-id

Identyfikator zadania platformy Spark.

--spark-pool-name

Nazwa puli Spark.

--workspace-name

Nazwa obszaru roboczego.

az synapse spark job submit

Edytuj

Prześlij zadanie platformy Spark.

az synapse spark job submit --executor-size {Large, Medium, Small}
                            --executors
                            --main-definition-file
                            --name
                            --spark-pool-name
                            --workspace-name
                            [--archives]
                            [--arguments]
                            [--configuration]
                            [--language {CSharp, PySpark, Python, Scala, Spark, SparkDotNet}]
                            [--main-class-name]
                            [--reference-files]
                            [--tags]

Przykłady

Prześlij zadanie Platformy Spark w języku Java.

az synapse spark job submit --name WordCount_Java --workspace-name testsynapseworkspace \
--spark-pool-name testsparkpool \
--main-definition-file abfss://testfilesystem@testadlsgen2.dfs.core.windows.net/samples/java/wordcount/wordcount.jar \
--main-class-name WordCount \
--arguments abfss://testfilesystem@testadlsgen2.dfs.core.windows.net/samples/java/wordcount/shakespeare.txt \
abfss://testfilesystem@testadlsgen2.dfs.core.windows.net/samples/java/wordcount/result/ \
--executors 2 --executor-size Small

Parametry wymagane

--executor-size

Rozmiar funkcji wykonawczej.

akceptowane wartości: Large, Medium, Small
--executors

Liczba funkcji wykonawczych.

--main-definition-file

Główny plik używany do zadania.

--name -n

Nazwa zadania platformy Spark.

--spark-pool-name

Nazwa puli Spark.

--workspace-name

Nazwa obszaru roboczego.

Parametry opcjonalne

--archives

Tablica archiwów.

--arguments

Opcjonalne argumenty zadania (Uwaga: użyj identyfikatorów URI magazynu dla argumentów plików).

--configuration

Konfiguracja zadania platformy Spark.

--language

Język zadań platformy Spark.

akceptowane wartości: CSharp, PySpark, Python, Scala, Spark, SparkDotNet
wartość domyślna: Scala
--main-class-name

W pełni kwalifikowany identyfikator lub klasa główna, która znajduje się w pliku definicji głównej.

--reference-files

Dodatkowe pliki używane do celów referencyjnych w pliku definicji głównej.

--tags

Tagi rozdzielone spacjami: klucz[=wartość] [klucz[=wartość] ...]. Użyj ciągu "", aby wyczyścić istniejące tagi.