New-AzureHDInsightMapReduceJobDefinition
Menentukan pekerjaan MapReduce baru.
Catatan
Cmdlet yang dirujuk dalam dokumentasi ini adalah untuk mengelola sumber daya Azure warisan yang menggunakan API Azure Service Manager (ASM). Modul PowerShell warisan ini tidak disarankan saat membuat sumber daya baru karena ASM dijadwalkan untuk dihentikan. Untuk informasi selengkapnya, lihat Penghentian Azure Service Manager.
Modul Az PowerShell adalah modul PowerShell yang direkomendasikan untuk mengelola sumber daya Azure Resource Manager (ARM) dengan PowerShell.
Sintaks
New-AzureHDInsightMapReduceJobDefinition
[-Arguments <String[]>]
-ClassName <String>
[-Defines <Hashtable>]
[-Files <String[]>]
-JarFile <String>
[-JobName <String>]
[-LibJars <String[]>]
[-StatusFolder <String>]
[-Profile <AzureSMProfile>]
[<CommonParameters>]
Deskripsi
Versi Azure PowerShell HDInsight ini tidak digunakan lagi. Cmdlet ini akan dihapus pada 1 Januari 2017. Silakan gunakan versi Azure PowerShell HDInsight yang lebih baru.
Untuk informasi tentang cara menggunakan HDInsight baru untuk membuat kluster, lihat Membuat kluster berbasis Linux di HDInsight menggunakan Azure PowerShell (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-hadoop-create-linux-clusters-azure-powershell/). Untuk informasi tentang cara mengirimkan pekerjaan dengan menggunakan Azure PowerShell dan pendekatan lainnya, lihat Mengirimkan pekerjaan Hadoop di HDInsight (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-submit-hadoop-jobs-programmatically/). Untuk informasi referensi tentang Azure PowerShell HDInsight, lihat Cmdlet Azure HDInsight.
Cmdlet New-AzureHDInsightMapReduceJobDefinition menentukan pekerjaan MapReduce baru untuk dijalankan pada kluster Azure HDInsight.
Contoh
Contoh 1: Tentukan pekerjaan MapReduce, jalankan pekerjaan, dan dapatkan output
PS C:\>$SubId = (Get-AzureSubscription -Current).SubscriptionId
PS C:\> $ClusterName = "MyCluster"
PS C:\> $WordCountJob = New-AzureHDInsightMapReduceJobDefinition -JarFile "/Example/Apps/Hadoop-examples.jar" -ClassName "WordCount" -Defines @{ "mapred.map.tasks" = "3" } -Arguments "/Example/Data/Gutenberg/Davinci.txt", "/Example/Output/WordCount"
PS C:\> $WordCountJob | Start-AzureHDInsightJob -Cluster $ClusterName
| Wait-AzureHDInsightJob -Subscription $SubId -WaitTimeoutInSeconds 3600
| Get-AzureHDInsightJobOutput -Cluster $ClusterName -Subscription $SubId -StandardError
Perintah pertama mendapatkan ID langganan saat ini, lalu menyimpannya dalam variabel $SubId.
Perintah kedua menetapkan nama MyCluster ke variabel $Clustername.
Perintah ketiga menggunakan cmdlet New-AzureHDInsightMapReduceJobDefinition untuk membuat definisi pekerjaan MapReduce, lalu menyimpannya dalam variabel $WordCountJob.
Perintah keempat melakukan urutan operasi dengan menggunakan cmdlet ini:
- Start-AzureHDInsightJob untuk memulai pekerjaan di $ClusterName.
- Wait-AzureHDInsightJob menunggu pekerjaan selesai dan menampilkan kemajuan menuju penyelesaian.
- Get-AzureHDInsightJobOutput untuk mendapatkan output pekerjaan.
Parameter
-Arguments
Menentukan rangkaian argumen untuk pekerjaan Hadoop. Argumen diteruskan sebagai argumen baris-perintah untuk tiap pekerjaan.
Jenis: | String[] |
Alias: | Args |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |
-ClassName
Menentukan nama kelas pekerjaan dalam file Arsip Java (JAR).
Jenis: | String |
Alias: | Class |
Position: | Named |
Nilai default: | None |
Diperlukan: | True |
Terima input alur: | False |
Terima karakter wildcard: | False |
-Defines
Menentukan nilai konfigurasi Hadoop untuk diatur saat pekerjaan berjalan.
Jenis: | Hashtable |
Alias: | Params |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |
-Files
Menentukan array file WASB yang diperlukan untuk pekerjaan.
Jenis: | String[] |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |
-JarFile
Menentukan nama file JAR yang sepenuhnya memenuhi syarat yang berisi kode dan dependensi pekerjaan MapReduce.
Jenis: | String |
Alias: | Jar |
Position: | Named |
Nilai default: | None |
Diperlukan: | True |
Terima input alur: | False |
Terima karakter wildcard: | False |
-JobName
Menentukan nama pekerjaan MapReduce. Parameter ini bersifat opsional. Jika Anda tidak menentukan parameter ini, nilai parameter ClassName digunakan.
Jenis: | String |
Alias: | Name |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |
-LibJars
Menentukan array referensi LibJar dari pekerjaan.
Jenis: | String[] |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |
-Profile
Menentukan profil Azure tempat cmdlet ini dibaca. Jika Anda tidak menentukan profil, cmdlet ini akan membaca dari profil default lokal.
Jenis: | AzureSMProfile |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |
-StatusFolder
Menentukan lokasi folder yang berisi output standar dan output kesalahan untuk pekerjaan, termasuk kode keluar dan log tugasnya.
Jenis: | String |
Position: | Named |
Nilai default: | None |
Diperlukan: | False |
Terima input alur: | False |
Terima karakter wildcard: | False |