New-AzureHDInsightStreamingMapReduceJobDefinition
Yeni bir akış MapReduce işi tanımlar.
Not
Bu belgelerde başvuruda bulunan cmdlet'ler, Hizmet Yönetimi API'lerini kullanan eski Azure kaynaklarını yönetmeye yöneliktir. Azure Resource Manager kaynaklarını yönetmek için cmdlet'ler için Az PowerShell modülüne bakın.
Syntax
New-AzureHDInsightStreamingMapReduceJobDefinition
[-Arguments <String[]>]
[-CmdEnv <String[]>]
[-Combiner <String>]
[-Defines <Hashtable>]
[-Files <String[]>]
[-InputPath <String>]
[-JobName <String>]
[-Mapper <String>]
[-OutputPath <String>]
[-Reducer <String>]
[-StatusFolder <String>]
[-Profile <AzureSMProfile>]
[<CommonParameters>] Description
Azure PowerShell HDInsight'ın bu sürümü kullanım dışıdır. Bu cmdlet'ler 1 Ocak 2017'ye kadar kaldırılacaktır. Lütfen Azure PowerShell HDInsight'ın daha yeni sürümünü kullanın.
Yeni HDInsight'ı kullanarak küme oluşturma hakkında bilgi için bkz . Azure PowerShell (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-hadoop-create-linux-clusters-azure-powershell/) kullanarak HDInsight'ta Linux tabanlı kümeler oluşturma. Azure PowerShell ve diğer yaklaşımları kullanarak iş gönderme hakkında bilgi için bkz . HDInsight'ta Hadoop işleri gönderme (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-submit-hadoop-jobs-programmatically/). Azure PowerShell HDInsight hakkında başvuru bilgileri için bkz . Azure HDInsight Cmdlet'leri.
New-AzureHDInsightStreamingMapReduceJobDefinition cmdlet'i, Hadoop akış işinin parametrelerini temsil eden yeni bir iş tanımı nesnesi tanımlar.
Örnekler
Örnek 1: MapReduce iş tanımı akışı oluşturma
PS C:\>$StreamingWordCount = New-AzureHDInsightStreamingMapReduceJobDefinition -Files "/Example/Apps/WordCount.exe", "/Example/Apps/Cat.exe" -InputPath "/Example/Data/Gutenberg/Davinci.txt" -OutputPath "/Example/Data/StreamingOutput/WordCount.txt" -Mapper "Cat.exe" -Reducer "WordCount.exe"Bu komut belirtilen akış MapReduce iş tanımını oluşturur ve $StreamingWordCount değişkeninde depolar.
Parametreler
-Arguments
Hadoop işi için bir bağımsız değişken dizisi belirtir. Bağımsız değişkenler her göreve komut satırı bağımsız değişkenleri olarak geçirilir.
| Type: | String[] |
| Aliases: | Args |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-CmdEnv
bir iş veri düğümlerinde çalıştırıldığında ayarlanacağı bir komut satırı ortam değişkenleri dizisi belirtir.
| Type: | String[] |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-Combiner
Bir Birleştirici dosya adını belirtir.
| Type: | String |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-Defines
İş çalıştırıldığında ayarlanacağı Hadoop yapılandırma değerlerini belirtir.
| Type: | Hashtable |
| Aliases: | Params |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-Files
bir iş için gereken dosya dizisini belirtir.
| Type: | String[] |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-InputPath
Giriş dosyalarının WASB yolunu belirtir.
| Type: | String |
| Aliases: | Input |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-JobName
Yeni MapReduce iş tanımının adını belirtir. Bu parametre isteğe bağlıdır.
| Type: | String |
| Aliases: | Name |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-Mapper
Bir Eşleyici dosya adı belirtir.
| Type: | String |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-OutputPath
İş çıkışı için WASB yolunu belirtir.
| Type: | String |
| Aliases: | Output |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-Profile
Bu cmdlet'in okuduğu Azure profilini belirtir. Bir profil belirtmezseniz, bu cmdlet yerel varsayılan profilden okur.
| Type: | AzureSMProfile |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-Reducer
Bir Azaltıcı dosya adı belirtir.
| Type: | String |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |
-StatusFolder
İş için çıkış kodu ve görev günlükleri dahil olmak üzere standart çıkışları ve hata çıkışlarını içeren klasörü belirtir.
| Type: | String |
| Position: | Named |
| Default value: | None |
| Required: | False |
| Accept pipeline input: | False |
| Accept wildcard characters: | False |